ruststream-sqlx 0.7.0

SQL databases for the RustStream messaging framework through sqlx: a transactional outbox over any RustStream broker and task queues in Postgres, MySQL/MariaDB and SQLite tables.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::Lease<DateTime<Utc>>>` and `Set<ruststream_sqlx::spec::Advisory>`
  --> tests/ui/manual_twice.rs:15:18
   |
15 |     type Table = InboxSpec<(Lease<DateTime<Utc>>, Advisory)>;
   |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::Advisory>>` is not implemented for `Set<ruststream_sqlx::spec::Lease<DateTime<Utc>>>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::Advisory>`
   = note: required for `(ruststream_sqlx::spec::Lease<DateTime<Utc>>, ruststream_sqlx::spec::Advisory)` to implement `ruststream_sqlx::spec::Declaration`
   = note: required for `InboxSpec<(ruststream_sqlx::spec::Lease<DateTime<Utc>>, ruststream_sqlx::spec::Advisory)>` to implement `Valid`
note: required by a bound in `ruststream_sqlx::InboxTable::Table`
  --> src/inbox/spec/builder.rs
   |
   |     type Table: Valid;
   |                 ^^^^^ required by this bound in `InboxTable::Table`

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::Attempt>` and `Set<ruststream_sqlx::spec::Attempt>`
  --> tests/ui/manual_twice.rs:32:18
   |
32 |     type Table = InboxSpec<(Attempt, Payload, Attempt)>;
   |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::Attempt>>` is not implemented for `Set<ruststream_sqlx::spec::Attempt>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::Attempt>`
   = note: required for `(ruststream_sqlx::spec::Attempt, ruststream_sqlx::spec::Payload, ruststream_sqlx::spec::Attempt)` to implement `ruststream_sqlx::spec::Declaration`
   = note: required for `InboxSpec<(ruststream_sqlx::spec::Attempt, ruststream_sqlx::spec::Payload, ruststream_sqlx::spec::Attempt)>` to implement `Valid`
note: required by a bound in `ruststream_sqlx::InboxTable::Table`
  --> src/inbox/spec/builder.rs
   |
   |     type Table: Valid;
   |                 ^^^^^ required by this bound in `InboxTable::Table`

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::own::Ack>` and `Set<ruststream_sqlx::spec::own::Ack>`
  --> tests/ui/manual_twice.rs:50:18
   |
50 |     type Table = InboxSpec<(own::Ack, own::Ack)>;
   |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::own::Ack>>` is not implemented for `Set<ruststream_sqlx::spec::own::Ack>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::own::Ack>`
   = note: required for `(ruststream_sqlx::spec::own::Ack, ruststream_sqlx::spec::own::Ack)` to implement `ruststream_sqlx::spec::Declaration`
   = note: required for `InboxSpec<(ruststream_sqlx::spec::own::Ack, ruststream_sqlx::spec::own::Ack)>` to implement `Valid`
note: required by a bound in `ruststream_sqlx::InboxTable::Table`
  --> src/inbox/spec/builder.rs
   |
   |     type Table: Valid;
   |                 ^^^^^ required by this bound in `InboxTable::Table`

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::Lease<_>>` and `Set<ruststream_sqlx::spec::Advisory>`
  --> tests/ui/manual_twice.rs:18:10
   |
18 |         .advisory(KEY);
   |          ^^^^^^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::Advisory>>` is not implemented for `Set<ruststream_sqlx::spec::Lease<_>>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::Advisory>`
   = note: required for `(ruststream_sqlx::spec::Lease<_>, ruststream_sqlx::spec::Advisory)` to implement `ruststream_sqlx::spec::Declaration`
note: required by a bound in `InboxSpec::<Settings>::advisory`
  --> src/inbox/spec/builder.rs
   |
   |     pub const fn advisory(
   |                  -------- required by a bound in this associated function
...
   |         <Settings as Push<Advisory>>::Out: Declaration,
   |                                            ^^^^^^^^^^^ required by this bound in `InboxSpec::<Settings>::advisory`

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::Attempt>` and `Set<ruststream_sqlx::spec::Attempt>`
  --> tests/ui/manual_twice.rs:36:10
   |
36 |         .attempt(Column::new("tries"));
   |          ^^^^^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::Attempt>>` is not implemented for `Set<ruststream_sqlx::spec::Attempt>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::Attempt>`
   = note: required for `(ruststream_sqlx::spec::Attempt, ruststream_sqlx::spec::Payload, ruststream_sqlx::spec::Attempt)` to implement `ruststream_sqlx::spec::Declaration`
note: required by a bound in `InboxSpec::<Settings>::attempt`
  --> src/inbox/spec/builder.rs
   |
   |     pub const fn attempt(
   |                  ------- required by a bound in this associated function
...
   |         <Settings as Push<Attempt>>::Out: Declaration,
   |                                           ^^^^^^^^^^^ required by this bound in `InboxSpec::<Settings>::attempt`

error[E0277]: a table sets this setting twice: `Set<ruststream_sqlx::spec::own::Ack>` and `Set<ruststream_sqlx::spec::own::Ack>`
  --> tests/ui/manual_twice.rs:53:10
   |
53 |         .own::<own::Ack>();
   |          ^^^ set twice
   |
   = note: a table sets each setting once: drop one of the two setter calls on its `InboxSpec` or `OutboxSpec`, and the marker from `type Table`
help: the trait `Merge<Set<ruststream_sqlx::spec::own::Ack>>` is not implemented for `Set<ruststream_sqlx::spec::own::Ack>`
      but trait `Merge<Unset>` is implemented for it
  --> src/settings.rs
   |
   | impl<Value> Merge<Unset> for Set<Value> {
   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   = help: for that trait implementation, expected `Unset`, found `Set<ruststream_sqlx::spec::own::Ack>`
   = note: required for `(ruststream_sqlx::spec::own::Ack, ruststream_sqlx::spec::own::Ack)` to implement `ruststream_sqlx::spec::Declaration`
note: required by a bound in `InboxSpec::<Settings>::own`
  --> src/inbox/spec/builder.rs
   |
   |     pub const fn own<Event: OwnEvent>(self) -> InboxSpec<<Settings as Push<Event>>::Out>
   |                  --- required by a bound in this associated function
...
   |         <Settings as Push<Event>>::Out: Declaration,
   |                                         ^^^^^^^^^^^ required by this bound in `InboxSpec::<Settings>::own`