Documentation
¶
Overview ¶
Package events is a generated GoMock package.
Package events is a generated GoMock package.
Index ¶
- Variables
- type MockStreamListener
- type MockStreamListenerFactory
- type MockStreamListenerFactoryMockRecorder
- type MockStreamListenerMockRecorder
- type MockStreamer
- type MockStreamerMockRecorder
- func (mr *MockStreamerMockRecorder) AddListener(arg0 interface{}) *gomock.Call
- func (mr *MockStreamerMockRecorder) Listeners() *gomock.Call
- func (mr *MockStreamerMockRecorder) RemoveListener(arg0 interface{}) *gomock.Call
- func (mr *MockStreamerMockRecorder) StartStream(arg0 interface{}) *gomock.Call
- type StreamListener
- type StreamListenerFactory
- type Streamer
Constants ¶
This section is empty.
Variables ¶
var (
// DefaultListenerBufSize defines the default buffer size for the stream listeners internal channel
DefaultListenerBufSize = 1000
)
var (
ErrListenerNotFound = errors.New("listener not found")
)
events errors
Functions ¶
This section is empty.
Types ¶
type MockStreamListener ¶
type MockStreamListener struct {
// contains filtered or unexported fields
}
MockStreamListener is a mock of StreamListener interface
func NewMockStreamListener ¶
func NewMockStreamListener(ctrl *gomock.Controller) *MockStreamListener
NewMockStreamListener creates a new mock instance
func (*MockStreamListener) C ¶
func (m *MockStreamListener) C() <-chan pb0.Event
C mocks base method
func (*MockStreamListener) Close ¶
func (m *MockStreamListener) Close() error
Close mocks base method
func (*MockStreamListener) EXPECT ¶
func (m *MockStreamListener) EXPECT() *MockStreamListenerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockStreamListenerFactory ¶
type MockStreamListenerFactory struct {
// contains filtered or unexported fields
}
MockStreamListenerFactory is a mock of StreamListenerFactory interface
func NewMockStreamListenerFactory ¶
func NewMockStreamListenerFactory(ctrl *gomock.Controller) *MockStreamListenerFactory
NewMockStreamListenerFactory creates a new mock instance
func (*MockStreamListenerFactory) Create ¶
func (m *MockStreamListenerFactory) Create(arg0 int, arg1 ...pb.EventType) StreamListener
Create mocks base method
func (*MockStreamListenerFactory) EXPECT ¶
func (m *MockStreamListenerFactory) EXPECT() *MockStreamListenerFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockStreamListenerFactoryMockRecorder ¶
type MockStreamListenerFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamListenerFactoryMockRecorder is the mock recorder for MockStreamListenerFactory
func (*MockStreamListenerFactoryMockRecorder) Create ¶
func (mr *MockStreamListenerFactoryMockRecorder) Create(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Create indicates an expected call of Create
type MockStreamListenerMockRecorder ¶
type MockStreamListenerMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamListenerMockRecorder is the mock recorder for MockStreamListener
func (*MockStreamListenerMockRecorder) C ¶
func (mr *MockStreamListenerMockRecorder) C() *gomock.Call
C indicates an expected call of C
func (*MockStreamListenerMockRecorder) Close ¶
func (mr *MockStreamListenerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
type MockStreamer ¶
type MockStreamer struct {
// contains filtered or unexported fields
}
MockStreamer is a mock of Streamer interface
func NewMockStreamer ¶
func NewMockStreamer(ctrl *gomock.Controller) *MockStreamer
NewMockStreamer creates a new mock instance
func (*MockStreamer) AddListener ¶
func (m *MockStreamer) AddListener(arg0 StreamListener)
AddListener mocks base method
func (*MockStreamer) EXPECT ¶
func (m *MockStreamer) EXPECT() *MockStreamerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStreamer) Listeners ¶
func (m *MockStreamer) Listeners() []StreamListener
Listeners mocks base method
func (*MockStreamer) RemoveListener ¶
func (m *MockStreamer) RemoveListener(arg0 StreamListener) error
RemoveListener mocks base method
func (*MockStreamer) StartStream ¶
func (m *MockStreamer) StartStream(arg0 context.Context) error
StartStream mocks base method
type MockStreamerMockRecorder ¶
type MockStreamerMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamerMockRecorder is the mock recorder for MockStreamer
func (*MockStreamerMockRecorder) AddListener ¶
func (mr *MockStreamerMockRecorder) AddListener(arg0 interface{}) *gomock.Call
AddListener indicates an expected call of AddListener
func (*MockStreamerMockRecorder) Listeners ¶
func (mr *MockStreamerMockRecorder) Listeners() *gomock.Call
Listeners indicates an expected call of Listeners
func (*MockStreamerMockRecorder) RemoveListener ¶
func (mr *MockStreamerMockRecorder) RemoveListener(arg0 interface{}) *gomock.Call
RemoveListener indicates an expected call of RemoveListener
func (*MockStreamerMockRecorder) StartStream ¶
func (mr *MockStreamerMockRecorder) StartStream(arg0 interface{}) *gomock.Call
StartStream indicates an expected call of StartStream
type StreamListener ¶
type StreamListener interface {
C() <-chan c2pb.Event
Close() error
// contains filtered or unexported methods
}
StreamListener defines a type able to listen for stream events
type StreamListenerFactory ¶
type StreamListenerFactory interface {
Create(eventChanBufSize int, eventTypeWhitelist ...pb.EventType) StreamListener
}
StreamListenerFactory defines a factory creating StreamListeners
func NewStreamListenerFactory ¶
func NewStreamListenerFactory(streamer Streamer) StreamListenerFactory
NewStreamListenerFactory creates a new StreamListener factory
type Streamer ¶
type Streamer interface {
StartStream(context.Context) error
AddListener(listener StreamListener)
RemoveListener(listener StreamListener) error
Listeners() []StreamListener
}
Streamer defines an interface to stream C2 events
func NewStreamer ¶
func NewStreamer(c2Client services.C2, logger log.FieldLogger) Streamer
NewStreamer creates a new streamer factory
Source Files