mocks

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationRegistry 

type ApplicationRegistry struct {
	mock.Mock
}

ApplicationRegistry is an autogenerated mock type for the ApplicationRegistry type

func NewApplicationRegistry 

func NewApplicationRegistry(t mockConstructorTestingTNewApplicationRegistry) *ApplicationRegistry

NewApplicationRegistry creates a new instance of ApplicationRegistry. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ApplicationRegistry) EXPECT 

func (_m *ApplicationRegistry) EXPECT() *ApplicationRegistry_Expecter

func (*ApplicationRegistry) GetApplication 

func (_m *ApplicationRegistry) GetApplication(ctx context.Context, applicationName string) (*funcie.Application, error)

GetApplication provides a mock function with given fields: ctx, applicationName

func (*ApplicationRegistry) Register 

func (_m *ApplicationRegistry) Register(ctx context.Context, application *funcie.Application) error

Register provides a mock function with given fields: ctx, application

func (*ApplicationRegistry) Unregister 

func (_m *ApplicationRegistry) Unregister(ctx context.Context, applicationName string) error

Unregister provides a mock function with given fields: ctx, applicationName

type ApplicationRegistry_Expecter 

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

func (*ApplicationRegistry_Expecter) GetApplication 

func (_e *ApplicationRegistry_Expecter) GetApplication(ctx interface{}, applicationName interface{}) *ApplicationRegistry_GetApplication_Call

GetApplication is a helper method to define mock.On call

  • ctx context.Context
  • applicationName string

func (*ApplicationRegistry_Expecter) Register 

func (_e *ApplicationRegistry_Expecter) Register(ctx interface{}, application interface{}) *ApplicationRegistry_Register_Call

Register is a helper method to define mock.On call

  • ctx context.Context
  • application *funcie.Application

func (*ApplicationRegistry_Expecter) Unregister 

func (_e *ApplicationRegistry_Expecter) Unregister(ctx interface{}, applicationName interface{}) *ApplicationRegistry_Unregister_Call

Unregister is a helper method to define mock.On call

  • ctx context.Context
  • applicationName string

type ApplicationRegistry_GetApplication_Call 

type ApplicationRegistry_GetApplication_Call struct {
	*mock.Call
}

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

func (*ApplicationRegistry_GetApplication_Call) Return 

func (_c *ApplicationRegistry_GetApplication_Call) Return(_a0 *funcie.Application, _a1 error) *ApplicationRegistry_GetApplication_Call

func (*ApplicationRegistry_GetApplication_Call) Run 

func (_c *ApplicationRegistry_GetApplication_Call) Run(run func(ctx context.Context, applicationName string)) *ApplicationRegistry_GetApplication_Call

func (*ApplicationRegistry_GetApplication_Call) RunAndReturn 

func (_c *ApplicationRegistry_GetApplication_Call) RunAndReturn(run func(context.Context, string) (*funcie.Application, error)) *ApplicationRegistry_GetApplication_Call

type ApplicationRegistry_Register_Call 

type ApplicationRegistry_Register_Call struct {
	*mock.Call
}

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

func (*ApplicationRegistry_Register_Call) Return 

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

func (*ApplicationRegistry_Register_Call) Run 

func (_c *ApplicationRegistry_Register_Call) Run(run func(ctx context.Context, application *funcie.Application)) *ApplicationRegistry_Register_Call

func (*ApplicationRegistry_Register_Call) RunAndReturn 

func (_c *ApplicationRegistry_Register_Call) RunAndReturn(run func(context.Context, *funcie.Application) error) *ApplicationRegistry_Register_Call

type ApplicationRegistry_Unregister_Call 

type ApplicationRegistry_Unregister_Call struct {
	*mock.Call
}

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

func (*ApplicationRegistry_Unregister_Call) Return 

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

func (*ApplicationRegistry_Unregister_Call) Run 

func (_c *ApplicationRegistry_Unregister_Call) Run(run func(ctx context.Context, applicationName string)) *ApplicationRegistry_Unregister_Call

func (*ApplicationRegistry_Unregister_Call) RunAndReturn 

func (_c *ApplicationRegistry_Unregister_Call) RunAndReturn(run func(context.Context, string) error) *ApplicationRegistry_Unregister_Call

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() error

Close provides a mock function with given fields:

func (*Client) EXPECT 

func (_m *Client) EXPECT() *Client_Expecter

func (*Client) HandleMessage 

func (_m *Client) HandleMessage(ctx context.Context, msg funcie.Message) error

HandleMessage provides a mock function with given fields: ctx, msg

type ClientHandlerRouter 

type ClientHandlerRouter struct {
	mock.Mock
}

ClientHandlerRouter is an autogenerated mock type for the ClientHandlerRouter type

func NewClientHandlerRouter 

func NewClientHandlerRouter(t mockConstructorTestingTNewClientHandlerRouter) *ClientHandlerRouter

NewClientHandlerRouter creates a new instance of ClientHandlerRouter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ClientHandlerRouter) AddClientHandler 

func (_m *ClientHandlerRouter) AddClientHandler(applicationId string, handler funcie.Handler) error

AddClientHandler provides a mock function with given fields: applicationId, handler

func (*ClientHandlerRouter) EXPECT 

func (_m *ClientHandlerRouter) EXPECT() *ClientHandlerRouter_Expecter

func (*ClientHandlerRouter) Handle 

func (_m *ClientHandlerRouter) Handle(ctx context.Context, message *funcie.Message) (*funcie.Response, error)

Handle provides a mock function with given fields: ctx, message

func (*ClientHandlerRouter) RemoveClientHandler 

func (_m *ClientHandlerRouter) RemoveClientHandler(applicationId string) error

RemoveClientHandler provides a mock function with given fields: applicationId

type ClientHandlerRouter_AddClientHandler_Call 

type ClientHandlerRouter_AddClientHandler_Call struct {
	*mock.Call
}

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

func (*ClientHandlerRouter_AddClientHandler_Call) Return 

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

func (*ClientHandlerRouter_AddClientHandler_Call) Run 

func (_c *ClientHandlerRouter_AddClientHandler_Call) Run(run func(applicationId string, handler funcie.Handler)) *ClientHandlerRouter_AddClientHandler_Call

func (*ClientHandlerRouter_AddClientHandler_Call) RunAndReturn 

func (_c *ClientHandlerRouter_AddClientHandler_Call) RunAndReturn(run func(string, funcie.Handler) error) *ClientHandlerRouter_AddClientHandler_Call

type ClientHandlerRouter_Expecter 

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

func (*ClientHandlerRouter_Expecter) AddClientHandler 

func (_e *ClientHandlerRouter_Expecter) AddClientHandler(applicationId interface{}, handler interface{}) *ClientHandlerRouter_AddClientHandler_Call

AddClientHandler is a helper method to define mock.On call

  • applicationId string
  • handler funcie.Handler

func (*ClientHandlerRouter_Expecter) Handle 

func (_e *ClientHandlerRouter_Expecter) Handle(ctx interface{}, message interface{}) *ClientHandlerRouter_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • message *funcie.Message

func (*ClientHandlerRouter_Expecter) RemoveClientHandler 

func (_e *ClientHandlerRouter_Expecter) RemoveClientHandler(applicationId interface{}) *ClientHandlerRouter_RemoveClientHandler_Call

RemoveClientHandler is a helper method to define mock.On call

  • applicationId string

type ClientHandlerRouter_Handle_Call 

type ClientHandlerRouter_Handle_Call struct {
	*mock.Call
}

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

func (*ClientHandlerRouter_Handle_Call) Return 

func (_c *ClientHandlerRouter_Handle_Call) Return(_a0 *funcie.Response, _a1 error) *ClientHandlerRouter_Handle_Call

func (*ClientHandlerRouter_Handle_Call) Run 

func (_c *ClientHandlerRouter_Handle_Call) Run(run func(ctx context.Context, message *funcie.Message)) *ClientHandlerRouter_Handle_Call

func (*ClientHandlerRouter_Handle_Call) RunAndReturn 

func (_c *ClientHandlerRouter_Handle_Call) RunAndReturn(run func(context.Context, *funcie.Message) (*funcie.Response, error)) *ClientHandlerRouter_Handle_Call

type ClientHandlerRouter_RemoveClientHandler_Call 

type ClientHandlerRouter_RemoveClientHandler_Call struct {
	*mock.Call
}

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

func (*ClientHandlerRouter_RemoveClientHandler_Call) Return 

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

func (*ClientHandlerRouter_RemoveClientHandler_Call) Run 

func (_c *ClientHandlerRouter_RemoveClientHandler_Call) Run(run func(applicationId string)) *ClientHandlerRouter_RemoveClientHandler_Call

func (*ClientHandlerRouter_RemoveClientHandler_Call) RunAndReturn 

func (_c *ClientHandlerRouter_RemoveClientHandler_Call) RunAndReturn(run func(string) error) *ClientHandlerRouter_RemoveClientHandler_Call

type ClientListener 

type ClientListener struct {
	mock.Mock
}

ClientListener is an autogenerated mock type for the ClientListener type

func NewClientListener 

func NewClientListener(t mockConstructorTestingTNewClientListener) *ClientListener

NewClientListener creates a new instance of ClientListener. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ClientListener) EXPECT 

func (_m *ClientListener) EXPECT() *ClientListener_Expecter

func (*ClientListener) ServeHTTP 

func (_m *ClientListener) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP provides a mock function with given fields: w, r

type ClientListener_Expecter 

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

func (*ClientListener_Expecter) ServeHTTP 

func (_e *ClientListener_Expecter) ServeHTTP(w interface{}, r interface{}) *ClientListener_ServeHTTP_Call

ServeHTTP is a helper method to define mock.On call

  • w http.ResponseWriter
  • r *http.Request

type ClientListener_ServeHTTP_Call 

type ClientListener_ServeHTTP_Call struct {
	*mock.Call
}

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

func (*ClientListener_ServeHTTP_Call) Return 

func (_c *ClientListener_ServeHTTP_Call) Return() *ClientListener_ServeHTTP_Call

func (*ClientListener_ServeHTTP_Call) Run 

func (_c *ClientListener_ServeHTTP_Call) Run(run func(w http.ResponseWriter, r *http.Request)) *ClientListener_ServeHTTP_Call

func (*ClientListener_ServeHTTP_Call) RunAndReturn 

func (_c *ClientListener_ServeHTTP_Call) RunAndReturn(run func(http.ResponseWriter, *http.Request)) *ClientListener_ServeHTTP_Call

type ClientManager 

type ClientManager struct {
	mock.Mock
}

ClientManager is an autogenerated mock type for the ClientManager type

func NewClientManager 

func NewClientManager(t mockConstructorTestingTNewClientManager) *ClientManager

NewClientManager creates a new instance of ClientManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ClientManager) AddClient 

func (_m *ClientManager) AddClient(conn publisher.Client)

AddClient provides a mock function with given fields: conn

func (*ClientManager) AddClientRouting 

func (_m *ClientManager) AddClientRouting(id string, conn publisher.Client)

AddClientRouting provides a mock function with given fields: id, conn

func (*ClientManager) CloseAllClients 

func (_m *ClientManager) CloseAllClients()

CloseAllClients provides a mock function with given fields:

func (*ClientManager) EXPECT 

func (_m *ClientManager) EXPECT() *ClientManager_Expecter

func (*ClientManager) GetClientRouting 

func (_m *ClientManager) GetClientRouting(id string) (publisher.Client, error)

GetClientRouting provides a mock function with given fields: id

func (*ClientManager) Process 

func (_m *ClientManager) Process(ctx context.Context, conn publisher.Websocket)

Process provides a mock function with given fields: ctx, conn

func (*ClientManager) RemoveClientRouting 

func (_m *ClientManager) RemoveClientRouting(id string)

RemoveClientRouting provides a mock function with given fields: id

type ClientManager_AddClientRouting_Call 

type ClientManager_AddClientRouting_Call struct {
	*mock.Call
}

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

func (*ClientManager_AddClientRouting_Call) Return 

func (_c *ClientManager_AddClientRouting_Call) Return() *ClientManager_AddClientRouting_Call

func (*ClientManager_AddClientRouting_Call) Run 

func (_c *ClientManager_AddClientRouting_Call) Run(run func(id string, conn publisher.Client)) *ClientManager_AddClientRouting_Call

func (*ClientManager_AddClientRouting_Call) RunAndReturn 

func (_c *ClientManager_AddClientRouting_Call) RunAndReturn(run func(string, publisher.Client)) *ClientManager_AddClientRouting_Call

type ClientManager_AddClient_Call 

type ClientManager_AddClient_Call struct {
	*mock.Call
}

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

func (*ClientManager_AddClient_Call) Return 

func (_c *ClientManager_AddClient_Call) Return() *ClientManager_AddClient_Call

func (*ClientManager_AddClient_Call) Run 

func (_c *ClientManager_AddClient_Call) Run(run func(conn publisher.Client)) *ClientManager_AddClient_Call

func (*ClientManager_AddClient_Call) RunAndReturn 

func (_c *ClientManager_AddClient_Call) RunAndReturn(run func(publisher.Client)) *ClientManager_AddClient_Call

type ClientManager_CloseAllClients_Call 

type ClientManager_CloseAllClients_Call struct {
	*mock.Call
}

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

func (*ClientManager_CloseAllClients_Call) Return 

func (_c *ClientManager_CloseAllClients_Call) Return() *ClientManager_CloseAllClients_Call

func (*ClientManager_CloseAllClients_Call) Run 

func (_c *ClientManager_CloseAllClients_Call) Run(run func()) *ClientManager_CloseAllClients_Call

func (*ClientManager_CloseAllClients_Call) RunAndReturn 

func (_c *ClientManager_CloseAllClients_Call) RunAndReturn(run func()) *ClientManager_CloseAllClients_Call

type ClientManager_Expecter 

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

func (*ClientManager_Expecter) AddClient 

func (_e *ClientManager_Expecter) AddClient(conn interface{}) *ClientManager_AddClient_Call

AddClient is a helper method to define mock.On call

  • conn publisher.Client

func (*ClientManager_Expecter) AddClientRouting 

func (_e *ClientManager_Expecter) AddClientRouting(id interface{}, conn interface{}) *ClientManager_AddClientRouting_Call

AddClientRouting is a helper method to define mock.On call

  • id string
  • conn publisher.Client

func (*ClientManager_Expecter) CloseAllClients 

func (_e *ClientManager_Expecter) CloseAllClients() *ClientManager_CloseAllClients_Call

CloseAllClients is a helper method to define mock.On call

func (*ClientManager_Expecter) GetClientRouting 

func (_e *ClientManager_Expecter) GetClientRouting(id interface{}) *ClientManager_GetClientRouting_Call

GetClientRouting is a helper method to define mock.On call

  • id string

func (*ClientManager_Expecter) Process 

func (_e *ClientManager_Expecter) Process(ctx interface{}, conn interface{}) *ClientManager_Process_Call

Process is a helper method to define mock.On call

  • ctx context.Context
  • conn publisher.Websocket

func (*ClientManager_Expecter) RemoveClientRouting 

func (_e *ClientManager_Expecter) RemoveClientRouting(id interface{}) *ClientManager_RemoveClientRouting_Call

RemoveClientRouting is a helper method to define mock.On call

  • id string

type ClientManager_GetClientRouting_Call 

type ClientManager_GetClientRouting_Call struct {
	*mock.Call
}

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

func (*ClientManager_GetClientRouting_Call) Return 

func (_c *ClientManager_GetClientRouting_Call) Return(_a0 publisher.Client, _a1 error) *ClientManager_GetClientRouting_Call

func (*ClientManager_GetClientRouting_Call) Run 

func (_c *ClientManager_GetClientRouting_Call) Run(run func(id string)) *ClientManager_GetClientRouting_Call

func (*ClientManager_GetClientRouting_Call) RunAndReturn 

func (_c *ClientManager_GetClientRouting_Call) RunAndReturn(run func(string) (publisher.Client, error)) *ClientManager_GetClientRouting_Call

type ClientManager_Process_Call 

type ClientManager_Process_Call struct {
	*mock.Call
}

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

func (*ClientManager_Process_Call) Return 

func (_c *ClientManager_Process_Call) Return() *ClientManager_Process_Call

func (*ClientManager_Process_Call) Run 

func (_c *ClientManager_Process_Call) Run(run func(ctx context.Context, conn publisher.Websocket)) *ClientManager_Process_Call

func (*ClientManager_Process_Call) RunAndReturn 

func (_c *ClientManager_Process_Call) RunAndReturn(run func(context.Context, publisher.Websocket)) *ClientManager_Process_Call

type ClientManager_RemoveClientRouting_Call 

type ClientManager_RemoveClientRouting_Call struct {
	*mock.Call
}

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

func (*ClientManager_RemoveClientRouting_Call) Return 

func (_c *ClientManager_RemoveClientRouting_Call) Return() *ClientManager_RemoveClientRouting_Call

func (*ClientManager_RemoveClientRouting_Call) Run 

func (_c *ClientManager_RemoveClientRouting_Call) Run(run func(id string)) *ClientManager_RemoveClientRouting_Call

func (*ClientManager_RemoveClientRouting_Call) RunAndReturn 

func (_c *ClientManager_RemoveClientRouting_Call) RunAndReturn(run func(string)) *ClientManager_RemoveClientRouting_Call

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(_a0 error) *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() error) *Client_Close_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) HandleMessage 

func (_e *Client_Expecter) HandleMessage(ctx interface{}, msg interface{}) *Client_HandleMessage_Call

HandleMessage is a helper method to define mock.On call

  • ctx context.Context
  • msg funcie.Message

type Client_HandleMessage_Call 

type Client_HandleMessage_Call struct {
	*mock.Call
}

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

func (*Client_HandleMessage_Call) Return 

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

func (*Client_HandleMessage_Call) Run 

func (_c *Client_HandleMessage_Call) Run(run func(ctx context.Context, msg funcie.Message)) *Client_HandleMessage_Call

func (*Client_HandleMessage_Call) RunAndReturn 

func (_c *Client_HandleMessage_Call) RunAndReturn(run func(context.Context, funcie.Message) error) *Client_HandleMessage_Call

type Closable 

type Closable struct {
	mock.Mock
}

Closable is an autogenerated mock type for the Closable type

func NewClosable 

func NewClosable(t mockConstructorTestingTNewClosable) *Closable

NewClosable creates a new instance of Closable. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Closable) Close 

func (_m *Closable) Close() error

Close provides a mock function with given fields:

func (*Closable) EXPECT 

func (_m *Closable) EXPECT() *Closable_Expecter

type Closable_Close_Call 

type Closable_Close_Call struct {
	*mock.Call
}

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

func (*Closable_Close_Call) Return 

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

func (*Closable_Close_Call) Run 

func (_c *Closable_Close_Call) Run(run func()) *Closable_Close_Call

func (*Closable_Close_Call) RunAndReturn 

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

type Closable_Expecter 

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

func (*Closable_Expecter) Close 

func (_e *Closable_Expecter) Close() *Closable_Close_Call

Close is a helper method to define mock.On call

type ConsumeClient 

type ConsumeClient struct {
	mock.Mock
}

ConsumeClient is an autogenerated mock type for the ConsumeClient type

func NewConsumeClient 

func NewConsumeClient(t mockConstructorTestingTNewConsumeClient) *ConsumeClient

NewConsumeClient creates a new instance of ConsumeClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ConsumeClient) EXPECT 

func (_m *ConsumeClient) EXPECT() *ConsumeClient_Expecter

func (*ConsumeClient) Publish 

func (_m *ConsumeClient) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd

Publish provides a mock function with given fields: ctx, channel, message

func (*ConsumeClient) RPush 

func (_m *ConsumeClient) RPush(ctx context.Context, key string, values ...interface{}) *redis.IntCmd

RPush provides a mock function with given fields: ctx, key, values

func (*ConsumeClient) Subscribe 

func (_m *ConsumeClient) Subscribe(ctx context.Context, channels ...string) transportsredis.PubSub

Subscribe provides a mock function with given fields: ctx, channels

type ConsumeClient_Expecter 

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

func (*ConsumeClient_Expecter) Publish 

func (_e *ConsumeClient_Expecter) Publish(ctx interface{}, channel interface{}, message interface{}) *ConsumeClient_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • channel string
  • message interface{}

func (*ConsumeClient_Expecter) RPush 

func (_e *ConsumeClient_Expecter) RPush(ctx interface{}, key interface{}, values ...interface{}) *ConsumeClient_RPush_Call

RPush is a helper method to define mock.On call

  • ctx context.Context
  • key string
  • values ...interface{}

func (*ConsumeClient_Expecter) Subscribe 

func (_e *ConsumeClient_Expecter) Subscribe(ctx interface{}, channels ...interface{}) *ConsumeClient_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • ctx context.Context
  • channels ...string

type ConsumeClient_Publish_Call 

type ConsumeClient_Publish_Call struct {
	*mock.Call
}

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

func (*ConsumeClient_Publish_Call) Return 

func (_c *ConsumeClient_Publish_Call) Return(_a0 *redis.IntCmd) *ConsumeClient_Publish_Call

func (*ConsumeClient_Publish_Call) Run 

func (_c *ConsumeClient_Publish_Call) Run(run func(ctx context.Context, channel string, message interface{})) *ConsumeClient_Publish_Call

func (*ConsumeClient_Publish_Call) RunAndReturn 

func (_c *ConsumeClient_Publish_Call) RunAndReturn(run func(context.Context, string, interface{}) *redis.IntCmd) *ConsumeClient_Publish_Call

type ConsumeClient_RPush_Call 

type ConsumeClient_RPush_Call struct {
	*mock.Call
}

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

func (*ConsumeClient_RPush_Call) Return 

func (_c *ConsumeClient_RPush_Call) Return(_a0 *redis.IntCmd) *ConsumeClient_RPush_Call

func (*ConsumeClient_RPush_Call) Run 

func (_c *ConsumeClient_RPush_Call) Run(run func(ctx context.Context, key string, values ...interface{})) *ConsumeClient_RPush_Call

func (*ConsumeClient_RPush_Call) RunAndReturn 

func (_c *ConsumeClient_RPush_Call) RunAndReturn(run func(context.Context, string, ...interface{}) *redis.IntCmd) *ConsumeClient_RPush_Call

type ConsumeClient_Subscribe_Call 

type ConsumeClient_Subscribe_Call struct {
	*mock.Call
}

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

func (*ConsumeClient_Subscribe_Call) Return 

func (_c *ConsumeClient_Subscribe_Call) Return(_a0 transportsredis.PubSub) *ConsumeClient_Subscribe_Call

func (*ConsumeClient_Subscribe_Call) Run 

func (_c *ConsumeClient_Subscribe_Call) Run(run func(ctx context.Context, channels ...string)) *ConsumeClient_Subscribe_Call

func (*ConsumeClient_Subscribe_Call) RunAndReturn 

func (_c *ConsumeClient_Subscribe_Call) RunAndReturn(run func(context.Context, ...string) transportsredis.PubSub) *ConsumeClient_Subscribe_Call

type Consumer 

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func NewConsumer 

func NewConsumer(t mockConstructorTestingTNewConsumer) *Consumer

NewConsumer creates a new instance of Consumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Consumer) Connect 

func (_m *Consumer) Connect(ctx context.Context) error

Connect provides a mock function with given fields: ctx

func (*Consumer) Consume 

func (_m *Consumer) Consume(ctx context.Context) error

Consume provides a mock function with given fields: ctx

func (*Consumer) EXPECT 

func (_m *Consumer) EXPECT() *Consumer_Expecter

func (*Consumer) Subscribe 

func (_m *Consumer) Subscribe(ctx context.Context, applicationId string, handler funcie.Handler) error

Subscribe provides a mock function with given fields: ctx, applicationId, handler

func (*Consumer) Unsubscribe 

func (_m *Consumer) Unsubscribe(ctx context.Context, applicationId string) error

Unsubscribe provides a mock function with given fields: ctx, applicationId

type Consumer_Connect_Call 

type Consumer_Connect_Call struct {
	*mock.Call
}

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

func (*Consumer_Connect_Call) Return 

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

func (*Consumer_Connect_Call) Run 

func (_c *Consumer_Connect_Call) Run(run func(ctx context.Context)) *Consumer_Connect_Call

func (*Consumer_Connect_Call) RunAndReturn 

func (_c *Consumer_Connect_Call) RunAndReturn(run func(context.Context) error) *Consumer_Connect_Call

type Consumer_Consume_Call 

type Consumer_Consume_Call struct {
	*mock.Call
}

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

func (*Consumer_Consume_Call) Return 

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

func (*Consumer_Consume_Call) Run 

func (_c *Consumer_Consume_Call) Run(run func(ctx context.Context)) *Consumer_Consume_Call

func (*Consumer_Consume_Call) RunAndReturn 

func (_c *Consumer_Consume_Call) RunAndReturn(run func(context.Context) error) *Consumer_Consume_Call

type Consumer_Expecter 

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

func (*Consumer_Expecter) Connect 

func (_e *Consumer_Expecter) Connect(ctx interface{}) *Consumer_Connect_Call

Connect is a helper method to define mock.On call

  • ctx context.Context

func (*Consumer_Expecter) Consume 

func (_e *Consumer_Expecter) Consume(ctx interface{}) *Consumer_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context

func (*Consumer_Expecter) Subscribe 

func (_e *Consumer_Expecter) Subscribe(ctx interface{}, applicationId interface{}, handler interface{}) *Consumer_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • ctx context.Context
  • applicationId string
  • handler funcie.Handler

func (*Consumer_Expecter) Unsubscribe 

func (_e *Consumer_Expecter) Unsubscribe(ctx interface{}, applicationId interface{}) *Consumer_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • ctx context.Context
  • applicationId string

type Consumer_Subscribe_Call 

type Consumer_Subscribe_Call struct {
	*mock.Call
}

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

func (*Consumer_Subscribe_Call) Return 

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

func (*Consumer_Subscribe_Call) Run 

func (_c *Consumer_Subscribe_Call) Run(run func(ctx context.Context, applicationId string, handler funcie.Handler)) *Consumer_Subscribe_Call

func (*Consumer_Subscribe_Call) RunAndReturn 

func (_c *Consumer_Subscribe_Call) RunAndReturn(run func(context.Context, string, funcie.Handler) error) *Consumer_Subscribe_Call

type Consumer_Unsubscribe_Call 

type Consumer_Unsubscribe_Call struct {
	*mock.Call
}

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

func (*Consumer_Unsubscribe_Call) Return 

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

func (*Consumer_Unsubscribe_Call) Run 

func (_c *Consumer_Unsubscribe_Call) Run(run func(ctx context.Context, applicationId string)) *Consumer_Unsubscribe_Call

func (*Consumer_Unsubscribe_Call) RunAndReturn 

func (_c *Consumer_Unsubscribe_Call) RunAndReturn(run func(context.Context, string) error) *Consumer_Unsubscribe_Call

type Handler 

type Handler struct {
	mock.Mock
}

Handler is an autogenerated mock type for the Handler type

func NewHandler 

func NewHandler(t mockConstructorTestingTNewHandler) *Handler

NewHandler creates a new instance of Handler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Handler) EXPECT 

func (_m *Handler) EXPECT() *Handler_Expecter

func (*Handler) Execute 

func (_m *Handler) Execute(ctx context.Context, message *funcie.Message) (*funcie.Response, error)

Execute provides a mock function with given fields: ctx, message

type Handler_Execute_Call 

type Handler_Execute_Call struct {
	*mock.Call
}

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

func (*Handler_Execute_Call) Return 

func (_c *Handler_Execute_Call) Return(_a0 *funcie.Response, _a1 error) *Handler_Execute_Call

func (*Handler_Execute_Call) Run 

func (_c *Handler_Execute_Call) Run(run func(ctx context.Context, message *funcie.Message)) *Handler_Execute_Call

func (*Handler_Execute_Call) RunAndReturn 

func (_c *Handler_Execute_Call) RunAndReturn(run func(context.Context, *funcie.Message) (*funcie.Response, error)) *Handler_Execute_Call

type Handler_Expecter 

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

func (*Handler_Expecter) Execute 

func (_e *Handler_Expecter) Execute(ctx interface{}, message interface{}) *Handler_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • message *funcie.Message

type PubSub 

type PubSub struct {
	mock.Mock
}

PubSub is an autogenerated mock type for the PubSub type

func NewPubSub 

func NewPubSub(t mockConstructorTestingTNewPubSub) *PubSub

NewPubSub creates a new instance of PubSub. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*PubSub) Channel 

func (_m *PubSub) Channel(opts ...redis.ChannelOption) <-chan *redis.Message

Channel provides a mock function with given fields: opts

func (*PubSub) Close 

func (_m *PubSub) Close() error

Close provides a mock function with given fields:

func (*PubSub) EXPECT 

func (_m *PubSub) EXPECT() *PubSub_Expecter

func (*PubSub) Receive 

func (_m *PubSub) Receive(ctx context.Context) (interface{}, error)

Receive provides a mock function with given fields: ctx

func (*PubSub) Subscribe 

func (_m *PubSub) Subscribe(ctx context.Context, channels ...string) error

Subscribe provides a mock function with given fields: ctx, channels

func (*PubSub) Unsubscribe 

func (_m *PubSub) Unsubscribe(ctx context.Context, channels ...string) error

Unsubscribe provides a mock function with given fields: ctx, channels

type PubSub_Channel_Call 

type PubSub_Channel_Call struct {
	*mock.Call
}

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

func (*PubSub_Channel_Call) Return 

func (_c *PubSub_Channel_Call) Return(_a0 <-chan *redis.Message) *PubSub_Channel_Call

func (*PubSub_Channel_Call) Run 

func (_c *PubSub_Channel_Call) Run(run func(opts ...redis.ChannelOption)) *PubSub_Channel_Call

func (*PubSub_Channel_Call) RunAndReturn 

func (_c *PubSub_Channel_Call) RunAndReturn(run func(...redis.ChannelOption) <-chan *redis.Message) *PubSub_Channel_Call

type PubSub_Close_Call 

type PubSub_Close_Call struct {
	*mock.Call
}

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

func (*PubSub_Close_Call) Return 

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

func (*PubSub_Close_Call) Run 

func (_c *PubSub_Close_Call) Run(run func()) *PubSub_Close_Call

func (*PubSub_Close_Call) RunAndReturn 

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

type PubSub_Expecter 

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

func (*PubSub_Expecter) Channel 

func (_e *PubSub_Expecter) Channel(opts ...interface{}) *PubSub_Channel_Call

Channel is a helper method to define mock.On call

  • opts ...redis.ChannelOption

func (*PubSub_Expecter) Close 

func (_e *PubSub_Expecter) Close() *PubSub_Close_Call

Close is a helper method to define mock.On call

func (*PubSub_Expecter) Receive 

func (_e *PubSub_Expecter) Receive(ctx interface{}) *PubSub_Receive_Call

Receive is a helper method to define mock.On call

  • ctx context.Context

func (*PubSub_Expecter) Subscribe 

func (_e *PubSub_Expecter) Subscribe(ctx interface{}, channels ...interface{}) *PubSub_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • ctx context.Context
  • channels ...string

func (*PubSub_Expecter) Unsubscribe 

func (_e *PubSub_Expecter) Unsubscribe(ctx interface{}, channels ...interface{}) *PubSub_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • ctx context.Context
  • channels ...string

type PubSub_Receive_Call 

type PubSub_Receive_Call struct {
	*mock.Call
}

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

func (*PubSub_Receive_Call) Return 

func (_c *PubSub_Receive_Call) Return(_a0 interface{}, _a1 error) *PubSub_Receive_Call

func (*PubSub_Receive_Call) Run 

func (_c *PubSub_Receive_Call) Run(run func(ctx context.Context)) *PubSub_Receive_Call

func (*PubSub_Receive_Call) RunAndReturn 

func (_c *PubSub_Receive_Call) RunAndReturn(run func(context.Context) (interface{}, error)) *PubSub_Receive_Call

type PubSub_Subscribe_Call 

type PubSub_Subscribe_Call struct {
	*mock.Call
}

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

func (*PubSub_Subscribe_Call) Return 

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

func (*PubSub_Subscribe_Call) Run 

func (_c *PubSub_Subscribe_Call) Run(run func(ctx context.Context, channels ...string)) *PubSub_Subscribe_Call

func (*PubSub_Subscribe_Call) RunAndReturn 

func (_c *PubSub_Subscribe_Call) RunAndReturn(run func(context.Context, ...string) error) *PubSub_Subscribe_Call

type PubSub_Unsubscribe_Call 

type PubSub_Unsubscribe_Call struct {
	*mock.Call
}

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

func (*PubSub_Unsubscribe_Call) Return 

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

func (*PubSub_Unsubscribe_Call) Run 

func (_c *PubSub_Unsubscribe_Call) Run(run func(ctx context.Context, channels ...string)) *PubSub_Unsubscribe_Call

func (*PubSub_Unsubscribe_Call) RunAndReturn 

func (_c *PubSub_Unsubscribe_Call) RunAndReturn(run func(context.Context, ...string) error) *PubSub_Unsubscribe_Call

type PublishClient 

type PublishClient struct {
	mock.Mock
}

PublishClient is an autogenerated mock type for the PublishClient type

func NewPublishClient 

func NewPublishClient(t mockConstructorTestingTNewPublishClient) *PublishClient

NewPublishClient creates a new instance of PublishClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*PublishClient) BRPop 

func (_m *PublishClient) BRPop(ctx context.Context, timeout time.Duration, keys ...string) *redis.StringSliceCmd

BRPop provides a mock function with given fields: ctx, timeout, keys

func (*PublishClient) EXPECT 

func (_m *PublishClient) EXPECT() *PublishClient_Expecter

func (*PublishClient) Publish 

func (_m *PublishClient) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd

Publish provides a mock function with given fields: ctx, channel, message

type PublishClient_BRPop_Call 

type PublishClient_BRPop_Call struct {
	*mock.Call
}

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

func (*PublishClient_BRPop_Call) Return 

func (_c *PublishClient_BRPop_Call) Return(_a0 *redis.StringSliceCmd) *PublishClient_BRPop_Call

func (*PublishClient_BRPop_Call) Run 

func (_c *PublishClient_BRPop_Call) Run(run func(ctx context.Context, timeout time.Duration, keys ...string)) *PublishClient_BRPop_Call

func (*PublishClient_BRPop_Call) RunAndReturn 

func (_c *PublishClient_BRPop_Call) RunAndReturn(run func(context.Context, time.Duration, ...string) *redis.StringSliceCmd) *PublishClient_BRPop_Call

type PublishClient_Expecter 

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

func (*PublishClient_Expecter) BRPop 

func (_e *PublishClient_Expecter) BRPop(ctx interface{}, timeout interface{}, keys ...interface{}) *PublishClient_BRPop_Call

BRPop is a helper method to define mock.On call

  • ctx context.Context
  • timeout time.Duration
  • keys ...string

func (*PublishClient_Expecter) Publish 

func (_e *PublishClient_Expecter) Publish(ctx interface{}, channel interface{}, message interface{}) *PublishClient_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • channel string
  • message interface{}

type PublishClient_Publish_Call 

type PublishClient_Publish_Call struct {
	*mock.Call
}

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

func (*PublishClient_Publish_Call) Return 

func (_c *PublishClient_Publish_Call) Return(_a0 *redis.IntCmd) *PublishClient_Publish_Call

func (*PublishClient_Publish_Call) Run 

func (_c *PublishClient_Publish_Call) Run(run func(ctx context.Context, channel string, message interface{})) *PublishClient_Publish_Call

func (*PublishClient_Publish_Call) RunAndReturn 

func (_c *PublishClient_Publish_Call) RunAndReturn(run func(context.Context, string, interface{}) *redis.IntCmd) *PublishClient_Publish_Call

type Publisher 

type Publisher struct {
	mock.Mock
}

Publisher is an autogenerated mock type for the Publisher type

func NewPublisher 

func NewPublisher(t mockConstructorTestingTNewPublisher) *Publisher

NewPublisher creates a new instance of Publisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Publisher) EXPECT 

func (_m *Publisher) EXPECT() *Publisher_Expecter

func (*Publisher) Publish 

func (_m *Publisher) Publish(ctx context.Context, message *funcie.Message) (*funcie.Response, error)

Publish provides a mock function with given fields: ctx, message

type Publisher_Expecter 

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

func (*Publisher_Expecter) Publish 

func (_e *Publisher_Expecter) Publish(ctx interface{}, message interface{}) *Publisher_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • message *funcie.Message

type Publisher_Publish_Call 

type Publisher_Publish_Call struct {
	*mock.Call
}

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

func (*Publisher_Publish_Call) Return 

func (_c *Publisher_Publish_Call) Return(_a0 *funcie.Response, _a1 error) *Publisher_Publish_Call

func (*Publisher_Publish_Call) Run 

func (_c *Publisher_Publish_Call) Run(run func(ctx context.Context, message *funcie.Message)) *Publisher_Publish_Call

func (*Publisher_Publish_Call) RunAndReturn 

func (_c *Publisher_Publish_Call) RunAndReturn(run func(context.Context, *funcie.Message) (*funcie.Response, error)) *Publisher_Publish_Call

type Tunnel 

type Tunnel struct {
	mock.Mock
}

Tunnel is an autogenerated mock type for the Tunnel type

func NewTunnel 

func NewTunnel(t mockConstructorTestingTNewTunnel) *Tunnel

NewTunnel creates a new instance of Tunnel. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Tunnel) EXPECT 

func (_m *Tunnel) EXPECT() *Tunnel_Expecter

func (*Tunnel) Start 

func (_m *Tunnel) Start()

Start provides a mock function with given fields:

type Tunnel_Expecter 

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

func (*Tunnel_Expecter) Start 

func (_e *Tunnel_Expecter) Start() *Tunnel_Start_Call

Start is a helper method to define mock.On call

type Tunnel_Start_Call 

type Tunnel_Start_Call struct {
	*mock.Call
}

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

func (*Tunnel_Start_Call) Return 

func (_c *Tunnel_Start_Call) Return() *Tunnel_Start_Call

func (*Tunnel_Start_Call) Run 

func (_c *Tunnel_Start_Call) Run(run func()) *Tunnel_Start_Call

func (*Tunnel_Start_Call) RunAndReturn 

func (_c *Tunnel_Start_Call) RunAndReturn(run func()) *Tunnel_Start_Call

type Websocket 

type Websocket struct {
	mock.Mock
}

Websocket is an autogenerated mock type for the Websocket type

func NewWebsocket 

func NewWebsocket(t mockConstructorTestingTNewWebsocket) *Websocket

NewWebsocket creates a new instance of Websocket. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Websocket) Close 

func (_m *Websocket) Close(code websocket.StatusCode, reason string) error

Close provides a mock function with given fields: code, reason

func (*Websocket) EXPECT 

func (_m *Websocket) EXPECT() *Websocket_Expecter

func (*Websocket) Read 

func (_m *Websocket) Read(ctx context.Context) (websocket.MessageType, []byte, error)

Read provides a mock function with given fields: ctx

func (*Websocket) Write 

func (_m *Websocket) Write(ctx context.Context, typ websocket.MessageType, p []byte) error

Write provides a mock function with given fields: ctx, typ, p

type WebsocketClient 

type WebsocketClient struct {
	mock.Mock
}

WebsocketClient is an autogenerated mock type for the WebsocketClient type

func NewWebsocketClient 

func NewWebsocketClient(t mockConstructorTestingTNewWebsocketClient) *WebsocketClient

NewWebsocketClient creates a new instance of WebsocketClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*WebsocketClient) Dial 

func (_m *WebsocketClient) Dial(ctx context.Context, u string, opts *websocket.DialOptions) (consumer.Websocket, *http.Response, error)

Dial provides a mock function with given fields: ctx, u, opts

func (*WebsocketClient) EXPECT 

func (_m *WebsocketClient) EXPECT() *WebsocketClient_Expecter

type WebsocketClient_Dial_Call 

type WebsocketClient_Dial_Call struct {
	*mock.Call
}

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

func (*WebsocketClient_Dial_Call) Return 

func (_c *WebsocketClient_Dial_Call) Return(_a0 consumer.Websocket, _a1 *http.Response, _a2 error) *WebsocketClient_Dial_Call

func (*WebsocketClient_Dial_Call) Run 

func (_c *WebsocketClient_Dial_Call) Run(run func(ctx context.Context, u string, opts *websocket.DialOptions)) *WebsocketClient_Dial_Call

func (*WebsocketClient_Dial_Call) RunAndReturn 

func (_c *WebsocketClient_Dial_Call) RunAndReturn(run func(context.Context, string, *websocket.DialOptions) (consumer.Websocket, *http.Response, error)) *WebsocketClient_Dial_Call

type WebsocketClient_Expecter 

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

func (*WebsocketClient_Expecter) Dial 

func (_e *WebsocketClient_Expecter) Dial(ctx interface{}, u interface{}, opts interface{}) *WebsocketClient_Dial_Call

Dial is a helper method to define mock.On call

  • ctx context.Context
  • u string
  • opts *websocket.DialOptions

type WebsocketServer 

type WebsocketServer struct {
	mock.Mock
}

WebsocketServer is an autogenerated mock type for the WebsocketServer type

func NewWebsocketServer 

func NewWebsocketServer(t mockConstructorTestingTNewWebsocketServer) *WebsocketServer

NewWebsocketServer creates a new instance of WebsocketServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*WebsocketServer) Accept 

func (_m *WebsocketServer) Accept(w http.ResponseWriter, r *http.Request, opts *websocket.AcceptOptions) (publisher.Websocket, error)

Accept provides a mock function with given fields: w, r, opts

func (*WebsocketServer) EXPECT 

func (_m *WebsocketServer) EXPECT() *WebsocketServer_Expecter

type WebsocketServer_Accept_Call 

type WebsocketServer_Accept_Call struct {
	*mock.Call
}

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

func (*WebsocketServer_Accept_Call) Return 

func (_c *WebsocketServer_Accept_Call) Return(_a0 publisher.Websocket, _a1 error) *WebsocketServer_Accept_Call

func (*WebsocketServer_Accept_Call) Run 

func (_c *WebsocketServer_Accept_Call) Run(run func(w http.ResponseWriter, r *http.Request, opts *websocket.AcceptOptions)) *WebsocketServer_Accept_Call

func (*WebsocketServer_Accept_Call) RunAndReturn 

func (_c *WebsocketServer_Accept_Call) RunAndReturn(run func(http.ResponseWriter, *http.Request, *websocket.AcceptOptions) (publisher.Websocket, error)) *WebsocketServer_Accept_Call

type WebsocketServer_Expecter 

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

func (*WebsocketServer_Expecter) Accept 

func (_e *WebsocketServer_Expecter) Accept(w interface{}, r interface{}, opts interface{}) *WebsocketServer_Accept_Call

Accept is a helper method to define mock.On call

  • w http.ResponseWriter
  • r *http.Request
  • opts *websocket.AcceptOptions

type Websocket_Close_Call 

type Websocket_Close_Call struct {
	*mock.Call
}

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

func (*Websocket_Close_Call) Return 

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

func (*Websocket_Close_Call) Run 

func (_c *Websocket_Close_Call) Run(run func(code websocket.StatusCode, reason string)) *Websocket_Close_Call

func (*Websocket_Close_Call) RunAndReturn 

func (_c *Websocket_Close_Call) RunAndReturn(run func(websocket.StatusCode, string) error) *Websocket_Close_Call

type Websocket_Expecter 

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

func (*Websocket_Expecter) Close 

func (_e *Websocket_Expecter) Close(code interface{}, reason interface{}) *Websocket_Close_Call

Close is a helper method to define mock.On call

  • code websocket.StatusCode
  • reason string

func (*Websocket_Expecter) Read 

func (_e *Websocket_Expecter) Read(ctx interface{}) *Websocket_Read_Call

Read is a helper method to define mock.On call

  • ctx context.Context

func (*Websocket_Expecter) Write 

func (_e *Websocket_Expecter) Write(ctx interface{}, typ interface{}, p interface{}) *Websocket_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • typ websocket.MessageType
  • p []byte

type Websocket_Read_Call 

type Websocket_Read_Call struct {
	*mock.Call
}

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

func (*Websocket_Read_Call) Return 

func (_c *Websocket_Read_Call) Return(_a0 websocket.MessageType, _a1 []byte, _a2 error) *Websocket_Read_Call

func (*Websocket_Read_Call) Run 

func (_c *Websocket_Read_Call) Run(run func(ctx context.Context)) *Websocket_Read_Call

func (*Websocket_Read_Call) RunAndReturn 

func (_c *Websocket_Read_Call) RunAndReturn(run func(context.Context) (websocket.MessageType, []byte, error)) *Websocket_Read_Call

type Websocket_Write_Call 

type Websocket_Write_Call struct {
	*mock.Call
}

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

func (*Websocket_Write_Call) Return 

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

func (*Websocket_Write_Call) Run 

func (_c *Websocket_Write_Call) Run(run func(ctx context.Context, typ websocket.MessageType, p []byte)) *Websocket_Write_Call

func (*Websocket_Write_Call) RunAndReturn 

func (_c *Websocket_Write_Call) RunAndReturn(run func(context.Context, websocket.MessageType, []byte) error) *Websocket_Write_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.