-
Notifications
You must be signed in to change notification settings - Fork 1
/
message_mock.go
92 lines (72 loc) · 2.2 KB
/
message_mock.go
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
package saga
import "time"
func newMockMessage() mockMessage {
return mockMessage{}
}
type mockMessage struct {
}
func (m mockMessage) ID() string {
//TODO implement me
panic("implement me")
}
func (m mockMessage) SessionID() string {
//TODO implement me
panic("implement me")
}
func (m mockMessage) Trigger() string {
//TODO implement me
panic("implement me")
}
func (m mockMessage) CreatedAt() time.Time {
//TODO implement me
panic("implement me")
}
func (m mockMessage) MarshalJSON() ([]byte, error) {
//TODO implement me
panic("implement me")
}
func newMockAbstractMessageRepository() *mockAbstractMessageRepository {
return &mockAbstractMessageRepository{}
}
type mockAbstractMessageRepository struct {
}
func (m *mockAbstractMessageRepository) GetMessagesFromOutbox(batchSize int) ([]mockMessage, error) {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) GetMessagesFromDeadLetter(batchSize int) ([]mockMessage, error) {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) SaveMessage(message mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) SaveMessages(messages []mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) SaveDeadLetter(message mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) SaveDeadLetters(message []mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) DeleteMessage(message mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) DeleteMessages(messages []mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) DeleteDeadLetter(message mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}
func (m *mockAbstractMessageRepository) DeleteDeadLetters(messages []mockMessage) Executable[mockTxContext] {
//TODO implement me
panic("implement me")
}