pkg

package

v0.0.0-...-4a8a90b Latest Latest Go to latest Published: Feb 28, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dimonleksin/kafka_reasign_partition

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func PrintHelp()
type Cluster
type Settings
- func (s Settings) Conf() (sarama.ClusterAdmin, error)
- func (s *Settings) GetSettings() error
type Topics
type XDGSCRAMClient

Constants ¶

View Source

const NumberOfBrockers int = 3

NumberOfBrockers need equal to replication factor in u cluster

Variables ¶

View Source

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

View Source

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions ¶

func PrintHelp ¶

func PrintHelp()

Types ¶

type Cluster ¶

type Cluster struct {
	Brokers         []Topics
	NumberOfBrokers int
}

func (Cluster) CreateRebalancePlane ¶

func (c Cluster) CreateRebalancePlane(to []int) (result Cluster, err error)

func (*Cluster) DescribeTopic ¶

func (c *Cluster) DescribeTopic(admin sarama.ClusterAdmin, topic []string) (err error)

Return current assign topics with format '<topic_name>-<partition_number>-<role>'

func (Cluster) ExtructPlane ¶

func (c Cluster) ExtructPlane(numberOfTopics int) (plane map[string][][]int32, err error)

func (*Cluster) GetCurrentBalance ¶

func (c *Cluster) GetCurrentBalance(admin sarama.ClusterAdmin, from int) (err error)

Returning list of brokers with topic.name-partitions-replicaAssigment

func (*Cluster) GetNumberOfBrokers ¶

func (c *Cluster) GetNumberOfBrokers(admin sarama.ClusterAdmin) (err error)

addded number of brokers from cluster to struct

func (Cluster) Rebalance ¶

func (c Cluster) Rebalance(admin sarama.ClusterAdmin, numberOfTopics int, Treads int) (err error)

type Settings ¶

type Settings struct {
	BrokersS                *string
	Brokers                 []string
	Action                  *string
	User                    *string
	Passwd                  *string
	From                    *int
	ToS                     *string
	To                      []int
	H                       *bool
	Help                    *bool
	TopicS                  *string
	Topics                  []string
	Treads                  *int
	Version                 *bool
	KafkaApiVersion         *string
	KafkaApiVersionFormated sarama.KafkaVersion
}

func (Settings) Conf ¶

func (s Settings) Conf() (sarama.ClusterAdmin, error)

func (*Settings) GetSettings ¶

func (s *Settings) GetSettings() error

type Topics ¶

type Topics struct {
	Topic   map[int]string
	Leaders int
}

type XDGSCRAMClient ¶

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin ¶

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done ¶

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step ¶

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL