topic

Documentation

Index

• func CompleteTopicNames(_ *cobra.Command, args []string, _ string) ([]string, cobra.ShellCompDirective)
• type AlterTopicFlags
• type CreateTopicFlags
• type DeleteRecordsFlags
• type DescribeTopicFlags
• type GetTopicsFlags
• type Operation
  • func (operation *Operation) AlterTopic(topic string, flags AlterTopicFlags) error
  • func (operation *Operation) CloneTopic(sourceTopic, targetTopic string) error
  • func (operation *Operation) CreateTopics(topics []string, flags CreateTopicFlags) error
  • func (operation *Operation) DeleteRecords(topic string, flags DeleteRecordsFlags) error
  • func (operation *Operation) DeleteTopics(topics []string) error
  • func (operation *Operation) DescribeTopic(topic string, flags DescribeTopicFlags) error
  • func (operation *Operation) GetTopics(flags GetTopicsFlags) error
  • func (operation *Operation) ListTopicsNames() ([]string, error)
• type Partition
• type PrintConfigsParam
• type Topic
  • func FromYaml(yamlString string) (Topic, error)

Functions

func CompleteTopicNames

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

Types

type AlterTopicFlags

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

type CreateTopicFlags

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

type DeleteRecordsFlags

type DeleteRecordsFlags struct {
	Offsets []string
}

type DescribeTopicFlags

type DescribeTopicFlags struct {
	PrintConfigs        PrintConfigsParam
	SkipEmptyPartitions bool
	OutputFormat        string
}

type GetTopicsFlags

type GetTopicsFlags struct {
	OutputFormat string
}

type Operation

type Operation struct {
}

func (*Operation) AlterTopic

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

func (*Operation) CloneTopic

func (operation *Operation) CloneTopic(sourceTopic, targetTopic string) error

func (*Operation) CreateTopics

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

func (*Operation) DeleteRecords

func (operation *Operation) DeleteRecords(topic string, flags DeleteRecordsFlags) error

func (*Operation) DeleteTopics

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

func (*Operation) DescribeTopic

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

func (*Operation) GetTopics

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

func (*Operation) ListTopicsNames

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

type Partition

type Partition struct {
	ID           int32
	OldestOffset int64   `json:"oldestOffset" yaml:"oldestOffset"`
	NewestOffset int64   `json:"newestOffset" yaml:"newestOffset"`
	Leader       string  `json:",omitempty" yaml:",omitempty"`
	Replicas     []int32 `json:",omitempty" yaml:",omitempty,flow"`
	ISRs         []int32 `json:"inSyncReplicas,omitempty" yaml:"inSyncReplicas,omitempty,flow"`
}

type PrintConfigsParam

type PrintConfigsParam string

const (
	NoConfigs         PrintConfigsParam = "none"
	AllConfigs        PrintConfigsParam = "all"
	NonDefaultConfigs PrintConfigsParam = "no_defaults"
)

type Topic

type Topic struct {
	Name       string
	Partitions []Partition       `json:",omitempty" yaml:",omitempty"`
	Configs    []internal.Config `json:",omitempty" yaml:",omitempty"`
}

func FromYaml

func FromYaml(yamlString string) (Topic, error)