mocks

Sep 22, 2023

Changes in this version

type Client

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

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

+ type Client_ConsumersExist_Call struct

+ 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) ConsumersExist(streamName interface{}) *Client_ConsumersExist_Call

+ func (_e *Client_Expecter) GetStreams() *Client_GetStreams_Call

+ type Client_GetStreams_Call struct

+ 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

Jul 19, 2023

Changes in this version

+ type Client struct

+ func NewClient(t interface{ ... }) *Client

+ func (_m *Client) Close()

+ func (_m *Client) EXPECT() *Client_Expecter

+ func (_m *Client) Init() error

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

+ type Client_Close_Call struct

+ 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_Expecter struct

+ func (_e *Client_Expecter) Close() *Client_Close_Call

+ func (_e *Client_Expecter) Init() *Client_Init_Call

+ func (_e *Client_Expecter) StreamExists() *Client_StreamExists_Call

+ type Client_Init_Call struct

+ 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 struct

+ 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