mocks

Documentation

Index

• type Client
  • func NewClient(t mockConstructorTestingTNewClient) *Client
  • func (_m *Client) Close()
  • func (_m *Client) CreateConsumer(name string, upsert bool, config nats.ConsumerConfig) error
  • func (_m *Client) GetConsumerConfig(name string) (*nats.ConsumerConfig, error)
  • func (_m *Client) IsConnected() bool
  • func (_m *Client) JetStreamCreateStream(streamName string) error
  • func (_m *Client) JetStreamPublish(_a0 string, _a1 []byte) error
  • func (_m *Client) JetStreamSubscribe(ctx context.Context, subj string, durable string, q chan *nats_go.Msg) (nats.UnsubscribeFunc, error)
  • func (_m *Client) StreamName() string

Types

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient

func NewClient(t mockConstructorTestingTNewClient) *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.

func (*Client) Close

func (_m *Client) Close()

Close provides a mock function with given fields:

func (*Client) CreateConsumer

func (_m *Client) CreateConsumer(name string, upsert bool, config nats.ConsumerConfig) error

CreateConsumer provides a mock function with given fields: name, upsert, config

func (*Client) GetConsumerConfig

func (_m *Client) GetConsumerConfig(name string) (*nats.ConsumerConfig, error)

GetConsumerConfig provides a mock function with given fields: name

func (*Client) IsConnected

func (_m *Client) IsConnected() bool

IsConnected provides a mock function with given fields:

func (*Client) JetStreamCreateStream

func (_m *Client) JetStreamCreateStream(streamName string) error

JetStreamCreateStream provides a mock function with given fields: streamName

func (*Client) JetStreamPublish

func (_m *Client) JetStreamPublish(_a0 string, _a1 []byte) error

JetStreamPublish provides a mock function with given fields: _a0, _a1

func (*Client) JetStreamSubscribe

func (_m *Client) JetStreamSubscribe(ctx context.Context, subj string, durable string, q chan *nats_go.Msg) (nats.UnsubscribeFunc, error)

JetStreamSubscribe provides a mock function with given fields: ctx, subj, durable, q

func (*Client) StreamName

func (_m *Client) StreamName() string

StreamName provides a mock function with given fields: