bamboo

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BambooHeartbeatPublisher 

type BambooHeartbeatPublisher struct {
	mock.Mock
}

BambooHeartbeatPublisher is an autogenerated mock type for the BambooHeartbeatPublisher type

func NewBambooHeartbeatPublisher 

func NewBambooHeartbeatPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooHeartbeatPublisher

NewBambooHeartbeatPublisher creates a new instance of BambooHeartbeatPublisher. 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 (*BambooHeartbeatPublisher) EXPECT 

func (_m *BambooHeartbeatPublisher) EXPECT() *BambooHeartbeatPublisher_Expecter

func (*BambooHeartbeatPublisher) Ping 

func (_m *BambooHeartbeatPublisher) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

func (*BambooHeartbeatPublisher) Run 

func (_m *BambooHeartbeatPublisher) Run(ctx context.Context, resultChannel string, heartbeatIntervalMSec int, done <-chan interface{}, aborted <-chan interface{}) error

Run provides a mock function with given fields: ctx, resultChannel, heartbeatIntervalMSec, done, aborted

type BambooHeartbeatPublisher_Expecter 

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

func (*BambooHeartbeatPublisher_Expecter) Ping 

func (_e *BambooHeartbeatPublisher_Expecter) Ping(ctx interface{}) *BambooHeartbeatPublisher_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

func (*BambooHeartbeatPublisher_Expecter) Run 

func (_e *BambooHeartbeatPublisher_Expecter) Run(ctx interface{}, resultChannel interface{}, heartbeatIntervalMSec interface{}, done interface{}, aborted interface{}) *BambooHeartbeatPublisher_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context
  • resultChannel string
  • heartbeatIntervalMSec int
  • done <-chan interface{}
  • aborted <-chan interface{}

type BambooHeartbeatPublisher_Ping_Call 

type BambooHeartbeatPublisher_Ping_Call struct {
	*mock.Call
}

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

func (*BambooHeartbeatPublisher_Ping_Call) Return 

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

func (*BambooHeartbeatPublisher_Ping_Call) Run 

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

func (*BambooHeartbeatPublisher_Ping_Call) RunAndReturn 

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

type BambooHeartbeatPublisher_Run_Call 

type BambooHeartbeatPublisher_Run_Call struct {
	*mock.Call
}

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

func (*BambooHeartbeatPublisher_Run_Call) Return 

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

func (*BambooHeartbeatPublisher_Run_Call) Run 

func (_c *BambooHeartbeatPublisher_Run_Call) Run(run func(ctx context.Context, resultChannel string, heartbeatIntervalMSec int, done <-chan interface{}, aborted <-chan interface{})) *BambooHeartbeatPublisher_Run_Call

func (*BambooHeartbeatPublisher_Run_Call) RunAndReturn 

func (_c *BambooHeartbeatPublisher_Run_Call) RunAndReturn(run func(context.Context, string, int, <-chan interface{}, <-chan interface{}) error) *BambooHeartbeatPublisher_Run_Call

type BambooRequestConsumer 

type BambooRequestConsumer struct {
	mock.Mock
}

BambooRequestConsumer is an autogenerated mock type for the BambooRequestConsumer type

func NewBambooRequestConsumer 

func NewBambooRequestConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooRequestConsumer

NewBambooRequestConsumer creates a new instance of BambooRequestConsumer. 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 (*BambooRequestConsumer) Close 

func (_m *BambooRequestConsumer) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*BambooRequestConsumer) Consume 

func (_m *BambooRequestConsumer) Consume(ctx context.Context) (*proto.WorkerParameter, error)

Consume provides a mock function with given fields: ctx

func (*BambooRequestConsumer) EXPECT 

func (_m *BambooRequestConsumer) EXPECT() *BambooRequestConsumer_Expecter

func (*BambooRequestConsumer) Ping 

func (_m *BambooRequestConsumer) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

type BambooRequestConsumer_Close_Call 

type BambooRequestConsumer_Close_Call struct {
	*mock.Call
}

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

func (*BambooRequestConsumer_Close_Call) Return 

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

func (*BambooRequestConsumer_Close_Call) Run 

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

func (*BambooRequestConsumer_Close_Call) RunAndReturn 

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

type BambooRequestConsumer_Consume_Call 

type BambooRequestConsumer_Consume_Call struct {
	*mock.Call
}

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

func (*BambooRequestConsumer_Consume_Call) Return 

func (_c *BambooRequestConsumer_Consume_Call) Return(_a0 *proto.WorkerParameter, _a1 error) *BambooRequestConsumer_Consume_Call

func (*BambooRequestConsumer_Consume_Call) Run 

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

func (*BambooRequestConsumer_Consume_Call) RunAndReturn 

func (_c *BambooRequestConsumer_Consume_Call) RunAndReturn(run func(context.Context) (*proto.WorkerParameter, error)) *BambooRequestConsumer_Consume_Call

type BambooRequestConsumer_Expecter 

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

func (*BambooRequestConsumer_Expecter) Close 

func (_e *BambooRequestConsumer_Expecter) Close(ctx interface{}) *BambooRequestConsumer_Close_Call

Close is a helper method to define mock.On call

  • ctx context.Context

func (*BambooRequestConsumer_Expecter) Consume 

func (_e *BambooRequestConsumer_Expecter) Consume(ctx interface{}) *BambooRequestConsumer_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context

func (*BambooRequestConsumer_Expecter) Ping 

func (_e *BambooRequestConsumer_Expecter) Ping(ctx interface{}) *BambooRequestConsumer_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

type BambooRequestConsumer_Ping_Call 

type BambooRequestConsumer_Ping_Call struct {
	*mock.Call
}

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

func (*BambooRequestConsumer_Ping_Call) Return 

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

func (*BambooRequestConsumer_Ping_Call) Run 

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

func (*BambooRequestConsumer_Ping_Call) RunAndReturn 

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

type BambooRequestProducer 

type BambooRequestProducer struct {
	mock.Mock
}

BambooRequestProducer is an autogenerated mock type for the BambooRequestProducer type

func NewBambooRequestProducer 

func NewBambooRequestProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooRequestProducer

NewBambooRequestProducer creates a new instance of BambooRequestProducer. 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 (*BambooRequestProducer) Close 

func (_m *BambooRequestProducer) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*BambooRequestProducer) EXPECT 

func (_m *BambooRequestProducer) EXPECT() *BambooRequestProducer_Expecter

func (*BambooRequestProducer) Produce 

func (_m *BambooRequestProducer) Produce(ctx context.Context, resultChannel string, heartbeatIntervalMSec int, jobTimeoutMSec int, headers map[string]string, data []byte) error

Produce provides a mock function with given fields: ctx, resultChannel, heartbeatIntervalMSec, jobTimeoutMSec, headers, data

type BambooRequestProducer_Close_Call 

type BambooRequestProducer_Close_Call struct {
	*mock.Call
}

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

func (*BambooRequestProducer_Close_Call) Return 

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

func (*BambooRequestProducer_Close_Call) Run 

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

func (*BambooRequestProducer_Close_Call) RunAndReturn 

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

type BambooRequestProducer_Expecter 

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

func (*BambooRequestProducer_Expecter) Close 

func (_e *BambooRequestProducer_Expecter) Close(ctx interface{}) *BambooRequestProducer_Close_Call

Close is a helper method to define mock.On call

  • ctx context.Context

func (*BambooRequestProducer_Expecter) Produce 

func (_e *BambooRequestProducer_Expecter) Produce(ctx interface{}, resultChannel interface{}, heartbeatIntervalMSec interface{}, jobTimeoutMSec interface{}, headers interface{}, data interface{}) *BambooRequestProducer_Produce_Call

Produce is a helper method to define mock.On call

  • ctx context.Context
  • resultChannel string
  • heartbeatIntervalMSec int
  • jobTimeoutMSec int
  • headers map[string]string
  • data []byte

type BambooRequestProducer_Produce_Call 

type BambooRequestProducer_Produce_Call struct {
	*mock.Call
}

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

func (*BambooRequestProducer_Produce_Call) Return 

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

func (*BambooRequestProducer_Produce_Call) Run 

func (_c *BambooRequestProducer_Produce_Call) Run(run func(ctx context.Context, resultChannel string, heartbeatIntervalMSec int, jobTimeoutMSec int, headers map[string]string, data []byte)) *BambooRequestProducer_Produce_Call

func (*BambooRequestProducer_Produce_Call) RunAndReturn 

func (_c *BambooRequestProducer_Produce_Call) RunAndReturn(run func(context.Context, string, int, int, map[string]string, []byte) error) *BambooRequestProducer_Produce_Call

type BambooResultPublisher 

type BambooResultPublisher struct {
	mock.Mock
}

BambooResultPublisher is an autogenerated mock type for the BambooResultPublisher type

func NewBambooResultPublisher 

func NewBambooResultPublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooResultPublisher

NewBambooResultPublisher creates a new instance of BambooResultPublisher. 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 (*BambooResultPublisher) EXPECT 

func (_m *BambooResultPublisher) EXPECT() *BambooResultPublisher_Expecter

func (*BambooResultPublisher) Ping 

func (_m *BambooResultPublisher) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

func (*BambooResultPublisher) Publish 

func (_m *BambooResultPublisher) Publish(ctx context.Context, resultChannel string, result []byte) error

Publish provides a mock function with given fields: ctx, resultChannel, result

type BambooResultPublisher_Expecter 

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

func (*BambooResultPublisher_Expecter) Ping 

func (_e *BambooResultPublisher_Expecter) Ping(ctx interface{}) *BambooResultPublisher_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

func (*BambooResultPublisher_Expecter) Publish 

func (_e *BambooResultPublisher_Expecter) Publish(ctx interface{}, resultChannel interface{}, result interface{}) *BambooResultPublisher_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • resultChannel string
  • result []byte

type BambooResultPublisher_Ping_Call 

type BambooResultPublisher_Ping_Call struct {
	*mock.Call
}

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

func (*BambooResultPublisher_Ping_Call) Return 

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

func (*BambooResultPublisher_Ping_Call) Run 

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

func (*BambooResultPublisher_Ping_Call) RunAndReturn 

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

type BambooResultPublisher_Publish_Call 

type BambooResultPublisher_Publish_Call struct {
	*mock.Call
}

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

func (*BambooResultPublisher_Publish_Call) Return 

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

func (*BambooResultPublisher_Publish_Call) Run 

func (_c *BambooResultPublisher_Publish_Call) Run(run func(ctx context.Context, resultChannel string, result []byte)) *BambooResultPublisher_Publish_Call

func (*BambooResultPublisher_Publish_Call) RunAndReturn 

func (_c *BambooResultPublisher_Publish_Call) RunAndReturn(run func(context.Context, string, []byte) error) *BambooResultPublisher_Publish_Call

type BambooResultSubscriber 

type BambooResultSubscriber struct {
	mock.Mock
}

BambooResultSubscriber is an autogenerated mock type for the BambooResultSubscriber type

func NewBambooResultSubscriber 

func NewBambooResultSubscriber(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooResultSubscriber

NewBambooResultSubscriber creates a new instance of BambooResultSubscriber. 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 (*BambooResultSubscriber) EXPECT 

func (_m *BambooResultSubscriber) EXPECT() *BambooResultSubscriber_Expecter

func (*BambooResultSubscriber) OpenSubscribeConnection 

func (_m *BambooResultSubscriber) OpenSubscribeConnection(ctx context.Context, resultChannel string) (SubscribeFunc, CloseSubscribeConnectionFunc, error)

OpenSubscribeConnection provides a mock function with given fields: ctx, resultChannel

func (*BambooResultSubscriber) Ping 

func (_m *BambooResultSubscriber) Ping(ctx context.Context) error

Ping provides a mock function with given fields: ctx

type BambooResultSubscriber_Expecter 

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

func (*BambooResultSubscriber_Expecter) OpenSubscribeConnection 

func (_e *BambooResultSubscriber_Expecter) OpenSubscribeConnection(ctx interface{}, resultChannel interface{}) *BambooResultSubscriber_OpenSubscribeConnection_Call

OpenSubscribeConnection is a helper method to define mock.On call

  • ctx context.Context
  • resultChannel string

func (*BambooResultSubscriber_Expecter) Ping 

func (_e *BambooResultSubscriber_Expecter) Ping(ctx interface{}) *BambooResultSubscriber_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context

type BambooResultSubscriber_OpenSubscribeConnection_Call 

type BambooResultSubscriber_OpenSubscribeConnection_Call struct {
	*mock.Call
}

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

func (*BambooResultSubscriber_OpenSubscribeConnection_Call) Return 

func (_c *BambooResultSubscriber_OpenSubscribeConnection_Call) Return(_a0 SubscribeFunc, _a1 CloseSubscribeConnectionFunc, _a2 error) *BambooResultSubscriber_OpenSubscribeConnection_Call

func (*BambooResultSubscriber_OpenSubscribeConnection_Call) Run 

func (_c *BambooResultSubscriber_OpenSubscribeConnection_Call) Run(run func(ctx context.Context, resultChannel string)) *BambooResultSubscriber_OpenSubscribeConnection_Call

func (*BambooResultSubscriber_OpenSubscribeConnection_Call) RunAndReturn 

func (_c *BambooResultSubscriber_OpenSubscribeConnection_Call) RunAndReturn(run func(context.Context, string) (SubscribeFunc, CloseSubscribeConnectionFunc, error)) *BambooResultSubscriber_OpenSubscribeConnection_Call

type BambooResultSubscriber_Ping_Call 

type BambooResultSubscriber_Ping_Call struct {
	*mock.Call
}

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

func (*BambooResultSubscriber_Ping_Call) Return 

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

func (*BambooResultSubscriber_Ping_Call) Run 

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

func (*BambooResultSubscriber_Ping_Call) RunAndReturn 

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

type BambooWorker 

type BambooWorker struct {
	mock.Mock
}

BambooWorker is an autogenerated mock type for the BambooWorker type

func NewBambooWorker 

func NewBambooWorker(t interface {
	mock.TestingT
	Cleanup(func())
}) *BambooWorker

NewBambooWorker creates a new instance of BambooWorker. 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 (*BambooWorker) EXPECT 

func (_m *BambooWorker) EXPECT() *BambooWorker_Expecter

func (*BambooWorker) Run 

func (_m *BambooWorker) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type BambooWorker_Expecter 

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

func (*BambooWorker_Expecter) Run 

func (_e *BambooWorker_Expecter) Run(ctx interface{}) *BambooWorker_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

type BambooWorker_Run_Call 

type BambooWorker_Run_Call struct {
	*mock.Call
}

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

func (*BambooWorker_Run_Call) Return 

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

func (*BambooWorker_Run_Call) Run 

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

func (*BambooWorker_Run_Call) RunAndReturn 

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

type CloseSubscribeConnectionFunc 

type CloseSubscribeConnectionFunc struct {
	mock.Mock
}

CloseSubscribeConnectionFunc is an autogenerated mock type for the CloseSubscribeConnectionFunc type

func NewCloseSubscribeConnectionFunc 

func NewCloseSubscribeConnectionFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *CloseSubscribeConnectionFunc

NewCloseSubscribeConnectionFunc creates a new instance of CloseSubscribeConnectionFunc. 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 (*CloseSubscribeConnectionFunc) EXPECT 

func (_m *CloseSubscribeConnectionFunc) EXPECT() *CloseSubscribeConnectionFunc_Expecter

func (*CloseSubscribeConnectionFunc) Execute 

func (_m *CloseSubscribeConnectionFunc) Execute(ctx context.Context) error

Execute provides a mock function with given fields: ctx

type CloseSubscribeConnectionFunc_Execute_Call 

type CloseSubscribeConnectionFunc_Execute_Call struct {
	*mock.Call
}

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

func (*CloseSubscribeConnectionFunc_Execute_Call) Return 

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

func (*CloseSubscribeConnectionFunc_Execute_Call) Run 

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

func (*CloseSubscribeConnectionFunc_Execute_Call) RunAndReturn 

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

type CloseSubscribeConnectionFunc_Expecter 

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

func (*CloseSubscribeConnectionFunc_Expecter) Execute 

func (_e *CloseSubscribeConnectionFunc_Expecter) Execute(ctx interface{}) *CloseSubscribeConnectionFunc_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

type SubscribeFunc 

type SubscribeFunc struct {
	mock.Mock
}

SubscribeFunc is an autogenerated mock type for the SubscribeFunc type

func NewSubscribeFunc 

func NewSubscribeFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscribeFunc

NewSubscribeFunc creates a new instance of SubscribeFunc. 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 (*SubscribeFunc) EXPECT 

func (_m *SubscribeFunc) EXPECT() *SubscribeFunc_Expecter

func (*SubscribeFunc) Execute 

func (_m *SubscribeFunc) Execute(ctx context.Context) (*proto.WorkerResponse, error)

Execute provides a mock function with given fields: ctx

type SubscribeFunc_Execute_Call 

type SubscribeFunc_Execute_Call struct {
	*mock.Call
}

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

func (*SubscribeFunc_Execute_Call) Return 

func (_c *SubscribeFunc_Execute_Call) Return(_a0 *proto.WorkerResponse, _a1 error) *SubscribeFunc_Execute_Call

func (*SubscribeFunc_Execute_Call) Run 

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

func (*SubscribeFunc_Execute_Call) RunAndReturn 

func (_c *SubscribeFunc_Execute_Call) RunAndReturn(run func(context.Context) (*proto.WorkerResponse, error)) *SubscribeFunc_Execute_Call

type SubscribeFunc_Expecter 

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

func (*SubscribeFunc_Expecter) Execute 

func (_e *SubscribeFunc_Expecter) Execute(ctx interface{}) *SubscribeFunc_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

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.
JackTT - Gopher 🇻🇳