Documentation
¶
Index ¶
- func NewNoopAdminClient() pubsubx.PubSubAdminClient
- func SetupInMemoryPubSub(l *logrusx.Logger, c *pubsubx.Config) (*memoryPubSub, error)
- type NoopAdminClient
- func (n *NoopAdminClient) Close()
- func (n *NoopAdminClient) CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, topic string, ...) (kadm.CreateTopicResponse, error)
- func (n *NoopAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)
- func (n *NoopAdminClient) HealthCheck(ctx context.Context) error
- func (n *NoopAdminClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewNoopAdminClient ¶
func NewNoopAdminClient() pubsubx.PubSubAdminClient
Types ¶
type NoopAdminClient ¶
type NoopAdminClient struct {
// contains filtered or unexported fields
}
func (*NoopAdminClient) Close ¶
func (n *NoopAdminClient) Close()
Close implements pubsubx.PubSubAdminClient.
func (*NoopAdminClient) CreateTopic ¶
func (n *NoopAdminClient) CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, topic string, configs ...map[string]*string) (kadm.CreateTopicResponse, error)
CreateTopic implements pubsubx.PubSubAdminClient.
func (*NoopAdminClient) DeleteTopic ¶
func (n *NoopAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)
DeleteTopic implements pubsubx.PubSubAdminClient.
func (*NoopAdminClient) HealthCheck ¶
func (n *NoopAdminClient) HealthCheck(ctx context.Context) error
HealthCheck implements pubsubx.PubSubAdminClient.
func (*NoopAdminClient) ListTopics ¶
func (n *NoopAdminClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)
ListTopics implements pubsubx.PubSubAdminClient.
Source Files
Click to show internal directories.
Click to hide internal directories.