operations

Documentation

Index

• func CompleteTopicNames(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)
• func CreateClient(context *ClientContext) (sarama.Client, error)
• func CreateClientConfig(context *ClientContext) (*sarama.Config, error)
• func CreateClusterAdmin(context *ClientContext) (sarama.ClusterAdmin, error)
• func TopicExists(client *sarama.Client, name string) (bool, error)
• type AlterTopicFlags
• type ClientContext
  • func CreateClientContext() (ClientContext, error)
• type CreateTopicFlags
• type DescribeTopicFlags
• type DocsFlags
• type DocsOperation
  • func (operation *DocsOperation) GenerateDocs(rootCmd *cobra.Command, flags DocsFlags) error
• type GetTopicsFlags
• type SaslConfig
• type TlsConfig
• type TopicOperation
  • func (operation *TopicOperation) AlterTopic(topic string, flags AlterTopicFlags) error
  • func (operation *TopicOperation) CreateTopics(topics []string, flags CreateTopicFlags) error
  • func (operation *TopicOperation) DeleteTopics(topics []string) error
  • func (operation *TopicOperation) DescribeTopic(topic string, flags DescribeTopicFlags) error
  • func (operation *TopicOperation) GetTopics(flags GetTopicsFlags) error
  • func (operation *TopicOperation) ListTopicsNames() ([]string, error)

Functions

func CompleteTopicNames

func CompleteTopicNames(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)

func CreateClient

func CreateClient(context *ClientContext) (sarama.Client, error)

func CreateClientConfig

func CreateClientConfig(context *ClientContext) (*sarama.Config, error)

func CreateClusterAdmin

func CreateClusterAdmin(context *ClientContext) (sarama.ClusterAdmin, error)

func TopicExists

func TopicExists(client *sarama.Client, name string) (bool, error)

Types

type AlterTopicFlags

type AlterTopicFlags struct {
	Partitions   int32
	ValidateOnly bool
	Configs      []string
}

type ClientContext

type ClientContext struct {
	Name               string
	Brokers            []string
	Tls                TlsConfig
	Sasl               SaslConfig
	ClientID           string
	KafkaVersion       sarama.KafkaVersion
	AvroSchemaRegistry string
	DefaultPartitioner string
}

func CreateClientContext

func CreateClientContext() (ClientContext, error)

type CreateTopicFlags

type CreateTopicFlags struct {
	Partitions        int32
	ReplicationFactor int16
	ValidateOnly      bool
	Configs           []string
}

type DescribeTopicFlags

type DescribeTopicFlags struct {
	PrintConfigs bool
	OutputFormat string
}

type DocsFlags

type DocsFlags struct {
	Directory  string
	DocType    string
	SinglePage bool
}

type DocsOperation

type DocsOperation struct {
}

func (*DocsOperation) GenerateDocs

func (operation *DocsOperation) GenerateDocs(rootCmd *cobra.Command, flags DocsFlags) error

type GetTopicsFlags

type GetTopicsFlags struct {
	OutputFormat string
}

type SaslConfig

type SaslConfig struct {
	Enabled  bool
	Username string
	Password string
}

type TlsConfig

type TlsConfig struct {
	Enabled  bool
	CA       string
	Cert     string
	CertKey  string
	Insecure bool
}

type TopicOperation

type TopicOperation struct {
}

func (*TopicOperation) AlterTopic

func (operation *TopicOperation) AlterTopic(topic string, flags AlterTopicFlags) error

func (*TopicOperation) CreateTopics

func (operation *TopicOperation) CreateTopics(topics []string, flags CreateTopicFlags) error

func (*TopicOperation) DeleteTopics

func (operation *TopicOperation) DeleteTopics(topics []string) error

func (*TopicOperation) DescribeTopic

func (operation *TopicOperation) DescribeTopic(topic string, flags DescribeTopicFlags) error

func (*TopicOperation) GetTopics

func (operation *TopicOperation) GetTopics(flags GetTopicsFlags) error

func (*TopicOperation) ListTopicsNames

func (operation *TopicOperation) ListTopicsNames() ([]string, error)