valitydev/fistful-proto
14
0
Fork 0
mirror of https://github.com/valitydev/fistful-proto.git synced 2024-11-06 01:15:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

TD-906: Retires indiscriminate EventSink services (#69)

Browse Source
This commit is contained in:
Aleksey Kashapov 2024-05-15 10:14:00 +03:00 committed by GitHub
parent 6600be9355
commit 0238425797
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
8 changed files with 1 additions and 183 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
proto/deposit.thrift
View File

@ -255,31 +255,6 @@ service Management {
)
}
/// Event sink
struct EventSinkPayload {
1: required eventsink.SequenceID sequence
2: required base.Timestamp occured_at
3: required list<Change> changes
}
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required DepositID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

25
proto/destination.thrift
View File

@ -132,31 +132,6 @@ union StatusChange {
1: Status changed
}
/// Event sink
struct EventSinkPayload {
1: required eventsink.SequenceID sequence
2: required base.Timestamp occured_at
3: required list<Change> changes
}
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required DestinationID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

19
proto/identity.thrift
View File

@ -203,25 +203,6 @@ union ChallengeChangePayload {
2: ChallengeStatus status_changed
}
/// Event sink
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required IdentityID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

25
proto/source.thrift
View File

@ -141,31 +141,6 @@ struct StatusChange {
1: required Status status
}
/// Event sink
struct EventSinkPayload {
1: required eventsink.SequenceID sequence
2: required base.Timestamp occured_at
3: required list<Change> changes
}
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required SourceID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

25
proto/w2w_transfer.thrift
View File

@ -177,31 +177,6 @@ service Management {
)
}
/// Event sink
struct EventSinkPayload {
1: required eventsink.SequenceID sequence
2: required base.Timestamp occured_at
3: required list<Change> changes
}
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required W2WTransferID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

19
proto/wallet.thrift
View File

@ -110,25 +110,6 @@ service Management {
throws (1: fistful.WalletNotFound ex1)
}
/// Event sink
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required WalletID source
4: required Event payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

25
proto/withdrawal.thrift
View File

@ -329,31 +329,6 @@ service Management {
)
}
/// Event sink
struct EventSinkPayload {
1: required eventsink.SequenceID sequence
2: required base.Timestamp occured_at
3: required list<Change> changes
}
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required WithdrawalID source
4: required EventSinkPayload payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {

19
proto/withdrawal_session.thrift
View File

@ -204,25 +204,6 @@ service Management {
)
}
/// Event sink
struct SinkEvent {
1: required eventsink.EventID id
2: required base.Timestamp created_at
3: required SessionID source
4: required Event payload
}
service EventSink {
list<SinkEvent> GetEvents (1: eventsink.EventRange range)
throws ()
eventsink.EventID GetLastEventID ()
throws (1: eventsink.NoLastEvent ex1)
}
/// Repair
union RepairScenario {