Documentation
¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: github.com/ecodeclub/mq-api (interfaces: Consumer)
Generated by this command:
mockgen -destination=internal/test/mocks/consumer.mock.go -package=mocks -typed=true github.com/ecodeclub/mq-api Consumer
Package mocks is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/ecodeclub/mq-api (interfaces: MQ)
Generated by this command:
mockgen -destination=internal/test/mocks/mq.mock.go -package=mocks -typed=true github.com/ecodeclub/mq-api MQ
Package mocks is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/ecodeclub/mq-api (interfaces: Producer)
Generated by this command:
mockgen -destination=internal/test/mocks/producer.mock.go -package=mocks -typed=true github.com/ecodeclub/mq-api Producer
Package mocks is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/ecodeclub/ginx/session (interfaces: Session)
Generated by this command:
mockgen -destination=internal/test/mocks/session.mock.go -package=mocks github.com/ecodeclub/ginx/session Session
Package mocks is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: github.com/ecodeclub/ginx/session (interfaces: Provider)
Generated by this command:
mockgen -destination=internal/test/mocks/session_provider.mock.go -package=mocks github.com/ecodeclub/ginx/session Provider
Package mocks is a generated GoMock package.
Index ¶
- type ConsumerCloseCall
- type ConsumerConsumeCall
- type ConsumerConsumeChanCall
- func (c *ConsumerConsumeChanCall) Do(f func(context.Context) (<-chan *mq.Message, error)) *ConsumerConsumeChanCall
- func (c *ConsumerConsumeChanCall) DoAndReturn(f func(context.Context) (<-chan *mq.Message, error)) *ConsumerConsumeChanCall
- func (c *ConsumerConsumeChanCall) Return(arg0 <-chan *mq.Message, arg1 error) *ConsumerConsumeChanCall
- type MQCloseCall
- type MQConsumerCall
- type MQCreateTopicCall
- type MQDeleteTopicsCall
- type MQProducerCall
- type MockConsumer
- type MockConsumerMockRecorder
- type MockMQ
- func (m *MockMQ) Close() error
- func (m *MockMQ) Consumer(arg0, arg1 string) (mq.Consumer, error)
- func (m *MockMQ) CreateTopic(arg0 context.Context, arg1 string, arg2 int) error
- func (m *MockMQ) DeleteTopics(arg0 context.Context, arg1 ...string) error
- func (m *MockMQ) EXPECT() *MockMQMockRecorder
- func (m *MockMQ) Producer(arg0 string) (mq.Producer, error)
- type MockMQMockRecorder
- func (mr *MockMQMockRecorder) Close() *MQCloseCall
- func (mr *MockMQMockRecorder) Consumer(arg0, arg1 any) *MQConsumerCall
- func (mr *MockMQMockRecorder) CreateTopic(arg0, arg1, arg2 any) *MQCreateTopicCall
- func (mr *MockMQMockRecorder) DeleteTopics(arg0 any, arg1 ...any) *MQDeleteTopicsCall
- func (mr *MockMQMockRecorder) Producer(arg0 any) *MQProducerCall
- type MockProducer
- func (m *MockProducer) Close() error
- func (m *MockProducer) EXPECT() *MockProducerMockRecorder
- func (m *MockProducer) Produce(arg0 context.Context, arg1 *mq.Message) (*mq.ProducerResult, error)
- func (m *MockProducer) ProduceWithPartition(arg0 context.Context, arg1 *mq.Message, arg2 int) (*mq.ProducerResult, error)
- type MockProducerMockRecorder
- type MockProvider
- func (m *MockProvider) Destroy(arg0 *gctx.Context) error
- func (m *MockProvider) EXPECT() *MockProviderMockRecorder
- func (m *MockProvider) Get(arg0 *gctx.Context) (session.Session, error)
- func (m *MockProvider) NewSession(arg0 *gctx.Context, arg1 int64, arg2 map[string]string, arg3 map[string]any) (session.Session, error)
- func (m *MockProvider) RenewAccessToken(arg0 *gctx.Context) error
- func (m *MockProvider) UpdateClaims(arg0 *gctx.Context, arg1 session.Claims) error
- type MockProviderMockRecorder
- func (mr *MockProviderMockRecorder) Destroy(arg0 any) *gomock.Call
- func (mr *MockProviderMockRecorder) Get(arg0 any) *gomock.Call
- func (mr *MockProviderMockRecorder) NewSession(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockProviderMockRecorder) RenewAccessToken(arg0 any) *gomock.Call
- func (mr *MockProviderMockRecorder) UpdateClaims(arg0, arg1 any) *gomock.Call
- type MockSession
- func (m *MockSession) Claims() session.Claims
- func (m *MockSession) Del(arg0 context.Context, arg1 string) error
- func (m *MockSession) Destroy(arg0 context.Context) error
- func (m *MockSession) EXPECT() *MockSessionMockRecorder
- func (m *MockSession) Get(arg0 context.Context, arg1 string) ekit.AnyValue
- func (m *MockSession) Set(arg0 context.Context, arg1 string, arg2 any) error
- type MockSessionMockRecorder
- func (mr *MockSessionMockRecorder) Claims() *gomock.Call
- func (mr *MockSessionMockRecorder) Del(arg0, arg1 any) *gomock.Call
- func (mr *MockSessionMockRecorder) Destroy(arg0 any) *gomock.Call
- func (mr *MockSessionMockRecorder) Get(arg0, arg1 any) *gomock.Call
- func (mr *MockSessionMockRecorder) Set(arg0, arg1, arg2 any) *gomock.Call
- type ProducerCloseCall
- type ProducerProduceCall
- func (c *ProducerProduceCall) Do(f func(context.Context, *mq.Message) (*mq.ProducerResult, error)) *ProducerProduceCall
- func (c *ProducerProduceCall) DoAndReturn(f func(context.Context, *mq.Message) (*mq.ProducerResult, error)) *ProducerProduceCall
- func (c *ProducerProduceCall) Return(arg0 *mq.ProducerResult, arg1 error) *ProducerProduceCall
- type ProducerProduceWithPartitionCall
- func (c *ProducerProduceWithPartitionCall) Do(f func(context.Context, *mq.Message, int) (*mq.ProducerResult, error)) *ProducerProduceWithPartitionCall
- func (c *ProducerProduceWithPartitionCall) DoAndReturn(f func(context.Context, *mq.Message, int) (*mq.ProducerResult, error)) *ProducerProduceWithPartitionCall
- func (c *ProducerProduceWithPartitionCall) Return(arg0 *mq.ProducerResult, arg1 error) *ProducerProduceWithPartitionCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerCloseCall ¶
ConsumerCloseCall wrap *gomock.Call
func (*ConsumerCloseCall) Do ¶
func (c *ConsumerCloseCall) Do(f func() error) *ConsumerCloseCall
Do rewrite *gomock.Call.Do
func (*ConsumerCloseCall) DoAndReturn ¶
func (c *ConsumerCloseCall) DoAndReturn(f func() error) *ConsumerCloseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ConsumerCloseCall) Return ¶
func (c *ConsumerCloseCall) Return(arg0 error) *ConsumerCloseCall
Return rewrite *gomock.Call.Return
type ConsumerConsumeCall ¶
ConsumerConsumeCall wrap *gomock.Call
func (*ConsumerConsumeCall) Do ¶
func (c *ConsumerConsumeCall) Do(f func(context.Context) (*mq.Message, error)) *ConsumerConsumeCall
Do rewrite *gomock.Call.Do
func (*ConsumerConsumeCall) DoAndReturn ¶
func (c *ConsumerConsumeCall) DoAndReturn(f func(context.Context) (*mq.Message, error)) *ConsumerConsumeCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ConsumerConsumeCall) Return ¶
func (c *ConsumerConsumeCall) Return(arg0 *mq.Message, arg1 error) *ConsumerConsumeCall
Return rewrite *gomock.Call.Return
type ConsumerConsumeChanCall ¶
ConsumerConsumeChanCall wrap *gomock.Call
func (*ConsumerConsumeChanCall) Do ¶
func (c *ConsumerConsumeChanCall) Do(f func(context.Context) (<-chan *mq.Message, error)) *ConsumerConsumeChanCall
Do rewrite *gomock.Call.Do
func (*ConsumerConsumeChanCall) DoAndReturn ¶
func (c *ConsumerConsumeChanCall) DoAndReturn(f func(context.Context) (<-chan *mq.Message, error)) *ConsumerConsumeChanCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ConsumerConsumeChanCall) Return ¶
func (c *ConsumerConsumeChanCall) Return(arg0 <-chan *mq.Message, arg1 error) *ConsumerConsumeChanCall
Return rewrite *gomock.Call.Return
type MQCloseCall ¶
MQCloseCall wrap *gomock.Call
func (*MQCloseCall) Do ¶
func (c *MQCloseCall) Do(f func() error) *MQCloseCall
Do rewrite *gomock.Call.Do
func (*MQCloseCall) DoAndReturn ¶
func (c *MQCloseCall) DoAndReturn(f func() error) *MQCloseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MQCloseCall) Return ¶
func (c *MQCloseCall) Return(arg0 error) *MQCloseCall
Return rewrite *gomock.Call.Return
type MQConsumerCall ¶
MQConsumerCall wrap *gomock.Call
func (*MQConsumerCall) Do ¶
func (c *MQConsumerCall) Do(f func(string, string) (mq.Consumer, error)) *MQConsumerCall
Do rewrite *gomock.Call.Do
func (*MQConsumerCall) DoAndReturn ¶
func (c *MQConsumerCall) DoAndReturn(f func(string, string) (mq.Consumer, error)) *MQConsumerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MQConsumerCall) Return ¶
func (c *MQConsumerCall) Return(arg0 mq.Consumer, arg1 error) *MQConsumerCall
Return rewrite *gomock.Call.Return
type MQCreateTopicCall ¶
MQCreateTopicCall wrap *gomock.Call
func (*MQCreateTopicCall) Do ¶
func (c *MQCreateTopicCall) Do(f func(context.Context, string, int) error) *MQCreateTopicCall
Do rewrite *gomock.Call.Do
func (*MQCreateTopicCall) DoAndReturn ¶
func (c *MQCreateTopicCall) DoAndReturn(f func(context.Context, string, int) error) *MQCreateTopicCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MQCreateTopicCall) Return ¶
func (c *MQCreateTopicCall) Return(arg0 error) *MQCreateTopicCall
Return rewrite *gomock.Call.Return
type MQDeleteTopicsCall ¶
MQDeleteTopicsCall wrap *gomock.Call
func (*MQDeleteTopicsCall) Do ¶
func (c *MQDeleteTopicsCall) Do(f func(context.Context, ...string) error) *MQDeleteTopicsCall
Do rewrite *gomock.Call.Do
func (*MQDeleteTopicsCall) DoAndReturn ¶
func (c *MQDeleteTopicsCall) DoAndReturn(f func(context.Context, ...string) error) *MQDeleteTopicsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MQDeleteTopicsCall) Return ¶
func (c *MQDeleteTopicsCall) Return(arg0 error) *MQDeleteTopicsCall
Return rewrite *gomock.Call.Return
type MQProducerCall ¶
MQProducerCall wrap *gomock.Call
func (*MQProducerCall) Do ¶
func (c *MQProducerCall) Do(f func(string) (mq.Producer, error)) *MQProducerCall
Do rewrite *gomock.Call.Do
func (*MQProducerCall) DoAndReturn ¶
func (c *MQProducerCall) DoAndReturn(f func(string) (mq.Producer, error)) *MQProducerCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MQProducerCall) Return ¶
func (c *MQProducerCall) Return(arg0 mq.Producer, arg1 error) *MQProducerCall
Return rewrite *gomock.Call.Return
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
MockConsumer is a mock of Consumer interface.
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
NewMockConsumer creates a new mock instance.
func (*MockConsumer) ConsumeChan ¶
ConsumeChan mocks base method.
func (*MockConsumer) EXPECT ¶
func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockConsumerMockRecorder ¶
type MockConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerMockRecorder is the mock recorder for MockConsumer.
func (*MockConsumerMockRecorder) Close ¶
func (mr *MockConsumerMockRecorder) Close() *ConsumerCloseCall
Close indicates an expected call of Close.
func (*MockConsumerMockRecorder) Consume ¶
func (mr *MockConsumerMockRecorder) Consume(arg0 any) *ConsumerConsumeCall
Consume indicates an expected call of Consume.
func (*MockConsumerMockRecorder) ConsumeChan ¶
func (mr *MockConsumerMockRecorder) ConsumeChan(arg0 any) *ConsumerConsumeChanCall
ConsumeChan indicates an expected call of ConsumeChan.
type MockMQ ¶
type MockMQ struct {
// contains filtered or unexported fields
}
MockMQ is a mock of MQ interface.
func NewMockMQ ¶
func NewMockMQ(ctrl *gomock.Controller) *MockMQ
NewMockMQ creates a new mock instance.
func (*MockMQ) CreateTopic ¶
CreateTopic mocks base method.
func (*MockMQ) DeleteTopics ¶
DeleteTopics mocks base method.
func (*MockMQ) EXPECT ¶
func (m *MockMQ) EXPECT() *MockMQMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockMQMockRecorder ¶
type MockMQMockRecorder struct {
// contains filtered or unexported fields
}
MockMQMockRecorder is the mock recorder for MockMQ.
func (*MockMQMockRecorder) Close ¶
func (mr *MockMQMockRecorder) Close() *MQCloseCall
Close indicates an expected call of Close.
func (*MockMQMockRecorder) Consumer ¶
func (mr *MockMQMockRecorder) Consumer(arg0, arg1 any) *MQConsumerCall
Consumer indicates an expected call of Consumer.
func (*MockMQMockRecorder) CreateTopic ¶
func (mr *MockMQMockRecorder) CreateTopic(arg0, arg1, arg2 any) *MQCreateTopicCall
CreateTopic indicates an expected call of CreateTopic.
func (*MockMQMockRecorder) DeleteTopics ¶
func (mr *MockMQMockRecorder) DeleteTopics(arg0 any, arg1 ...any) *MQDeleteTopicsCall
DeleteTopics indicates an expected call of DeleteTopics.
func (*MockMQMockRecorder) Producer ¶
func (mr *MockMQMockRecorder) Producer(arg0 any) *MQProducerCall
Producer indicates an expected call of Producer.
type MockProducer ¶
type MockProducer struct {
// contains filtered or unexported fields
}
MockProducer is a mock of Producer interface.
func NewMockProducer ¶
func NewMockProducer(ctrl *gomock.Controller) *MockProducer
NewMockProducer creates a new mock instance.
func (*MockProducer) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProducer) Produce ¶
func (m *MockProducer) Produce(arg0 context.Context, arg1 *mq.Message) (*mq.ProducerResult, error)
Produce mocks base method.
func (*MockProducer) ProduceWithPartition ¶
func (m *MockProducer) ProduceWithPartition(arg0 context.Context, arg1 *mq.Message, arg2 int) (*mq.ProducerResult, error)
ProduceWithPartition mocks base method.
type MockProducerMockRecorder ¶
type MockProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerMockRecorder is the mock recorder for MockProducer.
func (*MockProducerMockRecorder) Close ¶
func (mr *MockProducerMockRecorder) Close() *ProducerCloseCall
Close indicates an expected call of Close.
func (*MockProducerMockRecorder) Produce ¶
func (mr *MockProducerMockRecorder) Produce(arg0, arg1 any) *ProducerProduceCall
Produce indicates an expected call of Produce.
func (*MockProducerMockRecorder) ProduceWithPartition ¶
func (mr *MockProducerMockRecorder) ProduceWithPartition(arg0, arg1, arg2 any) *ProducerProduceWithPartitionCall
ProduceWithPartition indicates an expected call of ProduceWithPartition.
type MockProvider ¶
type MockProvider struct {
// contains filtered or unexported fields
}
MockProvider is a mock of Provider interface.
func NewMockProvider ¶
func NewMockProvider(ctrl *gomock.Controller) *MockProvider
NewMockProvider creates a new mock instance.
func (*MockProvider) Destroy ¶ added in v0.3.3
func (m *MockProvider) Destroy(arg0 *gctx.Context) error
Destroy mocks base method.
func (*MockProvider) EXPECT ¶
func (m *MockProvider) EXPECT() *MockProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProvider) NewSession ¶
func (m *MockProvider) NewSession(arg0 *gctx.Context, arg1 int64, arg2 map[string]string, arg3 map[string]any) (session.Session, error)
NewSession mocks base method.
func (*MockProvider) RenewAccessToken ¶
func (m *MockProvider) RenewAccessToken(arg0 *gctx.Context) error
RenewAccessToken mocks base method.
func (*MockProvider) UpdateClaims ¶
UpdateClaims mocks base method.
type MockProviderMockRecorder ¶
type MockProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockProviderMockRecorder is the mock recorder for MockProvider.
func (*MockProviderMockRecorder) Destroy ¶ added in v0.3.3
func (mr *MockProviderMockRecorder) Destroy(arg0 any) *gomock.Call
Destroy indicates an expected call of Destroy.
func (*MockProviderMockRecorder) Get ¶
func (mr *MockProviderMockRecorder) Get(arg0 any) *gomock.Call
Get indicates an expected call of Get.
func (*MockProviderMockRecorder) NewSession ¶
func (mr *MockProviderMockRecorder) NewSession(arg0, arg1, arg2, arg3 any) *gomock.Call
NewSession indicates an expected call of NewSession.
func (*MockProviderMockRecorder) RenewAccessToken ¶
func (mr *MockProviderMockRecorder) RenewAccessToken(arg0 any) *gomock.Call
RenewAccessToken indicates an expected call of RenewAccessToken.
func (*MockProviderMockRecorder) UpdateClaims ¶
func (mr *MockProviderMockRecorder) UpdateClaims(arg0, arg1 any) *gomock.Call
UpdateClaims indicates an expected call of UpdateClaims.
type MockSession ¶
type MockSession struct {
// contains filtered or unexported fields
}
MockSession is a mock of Session interface.
func NewMockSession ¶
func NewMockSession(ctrl *gomock.Controller) *MockSession
NewMockSession creates a new mock instance.
func (*MockSession) Claims ¶
func (m *MockSession) Claims() session.Claims
Claims mocks base method.
func (*MockSession) Del ¶
func (m *MockSession) Del(arg0 context.Context, arg1 string) error
Del mocks base method.
func (*MockSession) Destroy ¶
func (m *MockSession) Destroy(arg0 context.Context) error
Destroy mocks base method.
func (*MockSession) EXPECT ¶
func (m *MockSession) EXPECT() *MockSessionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockSessionMockRecorder ¶
type MockSessionMockRecorder struct {
// contains filtered or unexported fields
}
MockSessionMockRecorder is the mock recorder for MockSession.
func (*MockSessionMockRecorder) Claims ¶
func (mr *MockSessionMockRecorder) Claims() *gomock.Call
Claims indicates an expected call of Claims.
func (*MockSessionMockRecorder) Del ¶
func (mr *MockSessionMockRecorder) Del(arg0, arg1 any) *gomock.Call
Del indicates an expected call of Del.
func (*MockSessionMockRecorder) Destroy ¶
func (mr *MockSessionMockRecorder) Destroy(arg0 any) *gomock.Call
Destroy indicates an expected call of Destroy.
type ProducerCloseCall ¶
ProducerCloseCall wrap *gomock.Call
func (*ProducerCloseCall) Do ¶
func (c *ProducerCloseCall) Do(f func() error) *ProducerCloseCall
Do rewrite *gomock.Call.Do
func (*ProducerCloseCall) DoAndReturn ¶
func (c *ProducerCloseCall) DoAndReturn(f func() error) *ProducerCloseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProducerCloseCall) Return ¶
func (c *ProducerCloseCall) Return(arg0 error) *ProducerCloseCall
Return rewrite *gomock.Call.Return
type ProducerProduceCall ¶
ProducerProduceCall wrap *gomock.Call
func (*ProducerProduceCall) Do ¶
func (c *ProducerProduceCall) Do(f func(context.Context, *mq.Message) (*mq.ProducerResult, error)) *ProducerProduceCall
Do rewrite *gomock.Call.Do
func (*ProducerProduceCall) DoAndReturn ¶
func (c *ProducerProduceCall) DoAndReturn(f func(context.Context, *mq.Message) (*mq.ProducerResult, error)) *ProducerProduceCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProducerProduceCall) Return ¶
func (c *ProducerProduceCall) Return(arg0 *mq.ProducerResult, arg1 error) *ProducerProduceCall
Return rewrite *gomock.Call.Return
type ProducerProduceWithPartitionCall ¶
ProducerProduceWithPartitionCall wrap *gomock.Call
func (*ProducerProduceWithPartitionCall) Do ¶
func (c *ProducerProduceWithPartitionCall) Do(f func(context.Context, *mq.Message, int) (*mq.ProducerResult, error)) *ProducerProduceWithPartitionCall
Do rewrite *gomock.Call.Do
func (*ProducerProduceWithPartitionCall) DoAndReturn ¶
func (c *ProducerProduceWithPartitionCall) DoAndReturn(f func(context.Context, *mq.Message, int) (*mq.ProducerResult, error)) *ProducerProduceWithPartitionCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProducerProduceWithPartitionCall) Return ¶
func (c *ProducerProduceWithPartitionCall) Return(arg0 *mq.ProducerResult, arg1 error) *ProducerProduceWithPartitionCall
Return rewrite *gomock.Call.Return