-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmock.go
59 lines (45 loc) · 1.06 KB
/
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
package kadmin
import (
"context"
tea "github.com/charmbracelet/bubbletea"
"ktea/sradmin"
)
type MockKadmin struct {
}
func (m MockKadmin) CreateTopic(tcd TopicCreationDetails) tea.Msg {
return nil
}
func (m MockKadmin) DeleteTopic(topic string) tea.Msg {
return nil
}
func (m MockKadmin) ListTopics() tea.Msg {
return nil
}
func (m MockKadmin) PublishRecord(p *ProducerRecord) PublicationStartedMsg {
return PublicationStartedMsg{}
}
func (m MockKadmin) ReadRecords(ctx context.Context, rd ReadDetails) tea.Msg {
return ReadingStartedMsg{}
}
func (m MockKadmin) ListOffsets(group string) tea.Msg {
return nil
}
func (m MockKadmin) ListCGroups() tea.Msg {
return nil
}
func (m MockKadmin) DeleteCGroup(name string) tea.Msg {
return nil
}
func (m MockKadmin) UpdateConfig(t TopicConfigToUpdate) tea.Msg {
return nil
}
func (m MockKadmin) ListConfigs(topic string) tea.Msg {
return nil
}
func (m MockKadmin) SetSra(sra sradmin.SrAdmin) {
}
func NewMockKadmin() Instantiator {
return func(cd ConnectionDetails) (Kadmin, error) {
return &MockKadmin{}, nil
}
}