Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogStreamer ¶
LogStreamer is an autogenerated mock type for the LogStreamer type
func NewLogStreamer ¶
func NewLogStreamer(t mockConstructorTestingTNewLogStreamer) *LogStreamer
NewLogStreamer creates a new instance of LogStreamer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*LogStreamer) EXPECT ¶
func (_m *LogStreamer) EXPECT() *LogStreamer_Expecter
func (*LogStreamer) Stream ¶
func (_m *LogStreamer) Stream(ctx context.Context, services []database.Service, namespace string, allowedContainers []string, logChan chan<- []servicelogs.LogEntry, errChan chan<- error)
Stream provides a mock function with given fields: ctx, services, namespace, allowedContainers, logChan, errChan
type LogStreamer_Expecter ¶
type LogStreamer_Expecter struct {
// contains filtered or unexported fields
}
func (*LogStreamer_Expecter) Stream ¶
func (_e *LogStreamer_Expecter) Stream(ctx interface{}, services interface{}, namespace interface{}, allowedContainers interface{}, logChan interface{}, errChan interface{}) *LogStreamer_Stream_Call
Stream is a helper method to define mock.On call
- ctx context.Context
- services []database.Service
- namespace string
- allowedContainers []string
- logChan chan<- []servicelogs.LogEntry
- errChan chan<- error
type LogStreamer_Stream_Call ¶
LogStreamer_Stream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stream'
func (*LogStreamer_Stream_Call) Return ¶
func (_c *LogStreamer_Stream_Call) Return() *LogStreamer_Stream_Call
func (*LogStreamer_Stream_Call) Run ¶
func (_c *LogStreamer_Stream_Call) Run(run func(ctx context.Context, services []database.Service, namespace string, allowedContainers []string, logChan chan<- []servicelogs.LogEntry, errChan chan<- error)) *LogStreamer_Stream_Call
func (*LogStreamer_Stream_Call) RunAndReturn ¶
func (_c *LogStreamer_Stream_Call) RunAndReturn(run func(context.Context, []database.Service, string, []string, chan<- []servicelogs.LogEntry, chan<- error)) *LogStreamer_Stream_Call
Click to show internal directories.
Click to hide internal directories.