Documentation
¶
Index ¶
- type PubSub
- type PubSubAdminClient
- func (_m *PubSubAdminClient) Close()
- func (_m *PubSubAdminClient) CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, topic string, ...) (kadm.CreateTopicResponse, error)
- func (_m *PubSubAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)
- func (_m *PubSubAdminClient) HealthCheck(ctx context.Context) error
- func (_m *PubSubAdminClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)
- type PubSubOption
- type Publisher
- type Subscriber
- type SubscriberOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
PubSub is an autogenerated mock type for the PubSub type
func NewPubSub ¶
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. The first argument is typically a *testing.T value.
func (*PubSub) AdminClient ¶ added in v0.0.68
func (_m *PubSub) AdminClient() (pubsubx.PubSubAdminClient, error)
AdminClient provides a mock function with given fields:
func (*PubSub) Subscriber ¶
func (_m *PubSub) Subscriber(group string, topics []messagex.Topic, opts ...pubsubx.SubscriberOption) (pubsubx.Subscriber, error)
Subscriber provides a mock function with given fields: group, topics, opts
type PubSubAdminClient ¶ added in v0.0.68
PubSubAdminClient is an autogenerated mock type for the PubSubAdminClient type
func NewPubSubAdminClient ¶ added in v0.0.68
func NewPubSubAdminClient(t interface {
mock.TestingT
Cleanup(func())
}) *PubSubAdminClient
NewPubSubAdminClient creates a new instance of PubSubAdminClient. 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 (*PubSubAdminClient) Close ¶ added in v0.0.68
func (_m *PubSubAdminClient) Close()
Close provides a mock function with given fields:
func (*PubSubAdminClient) CreateTopic ¶ added in v0.0.68
func (_m *PubSubAdminClient) CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, topic string, configs ...map[string]*string) (kadm.CreateTopicResponse, error)
CreateTopic provides a mock function with given fields: ctx, partitions, replicationFactor, topic, configs
func (*PubSubAdminClient) DeleteTopic ¶ added in v0.0.68
func (_m *PubSubAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)
DeleteTopic provides a mock function with given fields: ctx, topic
func (*PubSubAdminClient) HealthCheck ¶ added in v0.0.68
func (_m *PubSubAdminClient) HealthCheck(ctx context.Context) error
HealthCheck provides a mock function with given fields: ctx
func (*PubSubAdminClient) ListTopics ¶ added in v0.0.68
func (_m *PubSubAdminClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)
ListTopics provides a mock function with given fields: ctx, topics
type PubSubOption ¶ added in v0.0.68
PubSubOption is an autogenerated mock type for the PubSubOption type
func NewPubSubOption ¶ added in v0.0.68
func NewPubSubOption(t interface {
mock.TestingT
Cleanup(func())
}) *PubSubOption
NewPubSubOption creates a new instance of PubSubOption. 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 (*PubSubOption) Execute ¶ added in v0.0.68
func (_m *PubSubOption) Execute(_a0 *pubsubx.PubSubOptions)
Execute provides a mock function with given fields: _a0
type Publisher ¶
Publisher is an autogenerated mock type for the Publisher type
func NewPublisher ¶
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. The first argument is typically a *testing.T value.
type Subscriber ¶
Subscriber is an autogenerated mock type for the Subscriber type
func NewSubscriber ¶
func NewSubscriber(t interface {
mock.TestingT
Cleanup(func())
}) *Subscriber
NewSubscriber creates a new instance of Subscriber. 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 (*Subscriber) Close ¶
func (_m *Subscriber) Close() error
Close provides a mock function with given fields:
func (*Subscriber) Health ¶ added in v0.0.69
func (_m *Subscriber) Health() error
Health provides a mock function with given fields:
type SubscriberOption ¶
SubscriberOption is an autogenerated mock type for the SubscriberOption type
func NewSubscriberOption ¶
func NewSubscriberOption(t interface {
mock.TestingT
Cleanup(func())
}) *SubscriberOption
NewSubscriberOption creates a new instance of SubscriberOption. 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 (*SubscriberOption) Execute ¶
func (_m *SubscriberOption) Execute(_a0 *pubsubx.SubscriberOptions)
Execute provides a mock function with given fields: _a0
Source Files