mocks

Documentation

Index

• type Client
  • func NewClient(t interface{ ... }) *Client
  • func (_m *Client) Close()
  • func (_m *Client) ConsumersExist(streamName string) (bool, error)
  • func (_m *Client) EXPECT() *Client_Expecter
  • func (_m *Client) GetStreams() ([]*nats_go.StreamInfo, error)
  • func (_m *Client) Init() error
  • func (_m *Client) StreamExists() (bool, error)
• type Client_Close_Call
  • func (_c *Client_Close_Call) Return() *Client_Close_Call
  • func (_c *Client_Close_Call) Run(run func()) *Client_Close_Call
  • func (_c *Client_Close_Call) RunAndReturn(run func()) *Client_Close_Call
• type Client_ConsumersExist_Call
  • func (_c *Client_ConsumersExist_Call) Return(_a0 bool, _a1 error) *Client_ConsumersExist_Call
  • func (_c *Client_ConsumersExist_Call) Run(run func(streamName string)) *Client_ConsumersExist_Call
  • func (_c *Client_ConsumersExist_Call) RunAndReturn(run func(string) (bool, error)) *Client_ConsumersExist_Call
• type Client_Expecter
  • func (_e *Client_Expecter) Close() *Client_Close_Call
  • func (_e *Client_Expecter) ConsumersExist(streamName interface{}) *Client_ConsumersExist_Call
  • func (_e *Client_Expecter) GetStreams() *Client_GetStreams_Call
  • func (_e *Client_Expecter) Init() *Client_Init_Call
  • func (_e *Client_Expecter) StreamExists() *Client_StreamExists_Call
• type Client_GetStreams_Call
  • func (_c *Client_GetStreams_Call) Return(_a0 []*nats_go.StreamInfo, _a1 error) *Client_GetStreams_Call
  • func (_c *Client_GetStreams_Call) Run(run func()) *Client_GetStreams_Call
  • func (_c *Client_GetStreams_Call) RunAndReturn(run func() ([]*nats_go.StreamInfo, error)) *Client_GetStreams_Call
• type Client_Init_Call
  • func (_c *Client_Init_Call) Return(_a0 error) *Client_Init_Call
  • func (_c *Client_Init_Call) Run(run func()) *Client_Init_Call
  • func (_c *Client_Init_Call) RunAndReturn(run func() error) *Client_Init_Call
• type Client_StreamExists_Call
  • func (_c *Client_StreamExists_Call) Return(_a0 bool, _a1 error) *Client_StreamExists_Call
  • func (_c *Client_StreamExists_Call) Run(run func()) *Client_StreamExists_Call
  • func (_c *Client_StreamExists_Call) RunAndReturn(run func() (bool, error)) *Client_StreamExists_Call

Types

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient

func NewClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *Client

NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Client) Close

func (_m *Client) Close()

Close provides a mock function with given fields:

func (*Client) ConsumersExist

func (_m *Client) ConsumersExist(streamName string) (bool, error)

ConsumersExist provides a mock function with given fields: streamName

func (*Client) EXPECT

func (_m *Client) EXPECT() *Client_Expecter

func (*Client) GetStreams

func (_m *Client) GetStreams() ([]*nats_go.StreamInfo, error)

GetStreams provides a mock function with given fields:

func (*Client) Init

func (_m *Client) Init() error

Init provides a mock function with given fields:

func (*Client) StreamExists

func (_m *Client) StreamExists() (bool, error)

StreamExists provides a mock function with given fields:

type Client_Close_Call

type Client_Close_Call struct {
	*mock.Call
}

Client_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Client_Close_Call) Return

func (_c *Client_Close_Call) Return() *Client_Close_Call

func (*Client_Close_Call) Run

func (_c *Client_Close_Call) Run(run func()) *Client_Close_Call

func (*Client_Close_Call) RunAndReturn

func (_c *Client_Close_Call) RunAndReturn(run func()) *Client_Close_Call

type Client_ConsumersExist_Call

type Client_ConsumersExist_Call struct {
	*mock.Call
}

Client_ConsumersExist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConsumersExist'

func (*Client_ConsumersExist_Call) Return

func (_c *Client_ConsumersExist_Call) Return(_a0 bool, _a1 error) *Client_ConsumersExist_Call

func (*Client_ConsumersExist_Call) Run

func (_c *Client_ConsumersExist_Call) Run(run func(streamName string)) *Client_ConsumersExist_Call

func (*Client_ConsumersExist_Call) RunAndReturn

func (_c *Client_ConsumersExist_Call) RunAndReturn(run func(string) (bool, error)) *Client_ConsumersExist_Call

type Client_Expecter

type Client_Expecter struct {
	// contains filtered or unexported fields
}

func (*Client_Expecter) Close

func (_e *Client_Expecter) Close() *Client_Close_Call

Close is a helper method to define mock.On call

func (*Client_Expecter) ConsumersExist

func (_e *Client_Expecter) ConsumersExist(streamName interface{}) *Client_ConsumersExist_Call

ConsumersExist is a helper method to define mock.On call

• streamName string

func (*Client_Expecter) GetStreams

func (_e *Client_Expecter) GetStreams() *Client_GetStreams_Call

GetStreams is a helper method to define mock.On call

func (*Client_Expecter) Init

func (_e *Client_Expecter) Init() *Client_Init_Call

Init is a helper method to define mock.On call

func (*Client_Expecter) StreamExists

func (_e *Client_Expecter) StreamExists() *Client_StreamExists_Call

StreamExists is a helper method to define mock.On call

type Client_GetStreams_Call

type Client_GetStreams_Call struct {
	*mock.Call
}

Client_GetStreams_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStreams'

func (*Client_GetStreams_Call) Return

func (_c *Client_GetStreams_Call) Return(_a0 []*nats_go.StreamInfo, _a1 error) *Client_GetStreams_Call

func (*Client_GetStreams_Call) Run

func (_c *Client_GetStreams_Call) Run(run func()) *Client_GetStreams_Call

func (*Client_GetStreams_Call) RunAndReturn

func (_c *Client_GetStreams_Call) RunAndReturn(run func() ([]*nats_go.StreamInfo, error)) *Client_GetStreams_Call

type Client_Init_Call

type Client_Init_Call struct {
	*mock.Call
}

Client_Init_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Init'

func (*Client_Init_Call) Return

func (_c *Client_Init_Call) Return(_a0 error) *Client_Init_Call

func (*Client_Init_Call) Run

func (_c *Client_Init_Call) Run(run func()) *Client_Init_Call

func (*Client_Init_Call) RunAndReturn

func (_c *Client_Init_Call) RunAndReturn(run func() error) *Client_Init_Call

type Client_StreamExists_Call

type Client_StreamExists_Call struct {
	*mock.Call
}

Client_StreamExists_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamExists'

func (*Client_StreamExists_Call) Return

func (_c *Client_StreamExists_Call) Return(_a0 bool, _a1 error) *Client_StreamExists_Call

func (*Client_StreamExists_Call) Run

func (_c *Client_StreamExists_Call) Run(run func()) *Client_StreamExists_Call

func (*Client_StreamExists_Call) RunAndReturn

func (_c *Client_StreamExists_Call) RunAndReturn(run func() (bool, error)) *Client_StreamExists_Call