inmemorypubsub

Documentation

Index

• func NewNoopAdminClient(c *pubsubx.Config) 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) CreateTopics(ctx context.Context, partitions int32, replicationFactor int16, ...) (kadm.CreateTopicResponses, error)
  • func (n *NoopAdminClient) DeleteGroup(ctx context.Context, group messagex.ConsumerGroup) (kadm.DeleteGroupResponse, error)
  • func (n *NoopAdminClient) DeleteGroups(ctx context.Context, groups ...messagex.ConsumerGroup) (kadm.DeleteGroupResponses, error)
  • func (n *NoopAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)
  • func (n *NoopAdminClient) DeleteTopicWithRetryTopics(ctx context.Context, topic string) (kadm.DeleteTopicResponses, error)
  • func (n *NoopAdminClient) DeleteTopicsWithRetryTopics(ctx context.Context, topics ...string) (kadm.DeleteTopicResponses, error)
  • func (n *NoopAdminClient) HealthCheck(ctx context.Context) error
  • func (n *NoopAdminClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)

Functions

func NewNoopAdminClient

func NewNoopAdminClient(c *pubsubx.Config) pubsubx.PubSubAdminClient

func SetupInMemoryPubSub

func SetupInMemoryPubSub(l *logrusx.Logger, c *pubsubx.Config) (*memoryPubSub, error)

Types

type NoopAdminClient

type NoopAdminClient struct {
	*pubsubx.Config
	// 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) CreateTopics

func (n *NoopAdminClient) CreateTopics(ctx context.Context, partitions int32, replicationFactor int16, topics []string, configs ...map[string]*string) (kadm.CreateTopicResponses, error)

CreateTopic implements pubsubx.PubSubAdminClient.

func (*NoopAdminClient) DeleteGroup

func (n *NoopAdminClient) DeleteGroup(ctx context.Context, group messagex.ConsumerGroup) (kadm.DeleteGroupResponse, error)

func (*NoopAdminClient) DeleteGroups

func (n *NoopAdminClient) DeleteGroups(ctx context.Context, groups ...messagex.ConsumerGroup) (kadm.DeleteGroupResponses, error)

DeleteGroups deletes groups and related resources.

func (*NoopAdminClient) DeleteTopic

func (n *NoopAdminClient) DeleteTopic(ctx context.Context, topic string) (kadm.DeleteTopicResponse, error)

DeleteTopic implements pubsubx.PubSubAdminClient.

func (*NoopAdminClient) DeleteTopicWithRetryTopics

func (n *NoopAdminClient) DeleteTopicWithRetryTopics(ctx context.Context, topic string) (kadm.DeleteTopicResponses, error)

func (*NoopAdminClient) DeleteTopicsWithRetryTopics

func (n *NoopAdminClient) DeleteTopicsWithRetryTopics(ctx context.Context, topics ...string) (kadm.DeleteTopicResponses, error)

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.