cluster

Documentation

Index

• Variables
• func New(newBroker NewBrokerFunc, brokers []string) model.Cluster
• type C
  • func (c *C) Coordinator(group string) (model.Broker, error)
  • func (c *C) CoordinatorIsDown(group string)
  • func (c *C) Leader(topic string, partition int32) (model.Broker, error)
  • func (c *C) LeaderIsDown(topic string, partition int32)
  • func (c *C) Partitions(topic string) ([]int32, error)
• type MultiError
  • func (es *MultiError) Add(err error)
  • func (es MultiError) Error() string
• type NewBrokerFunc

Variables

var (
	ErrLeaderNotFound = errors.New("leader not found")
	ErrCoordNotFound  = errors.New("coordinator not found")
	ErrNoBrokerFound  = errors.New("no broker found")
)

Functions

func New

func New(newBroker NewBrokerFunc, brokers []string) model.Cluster

Types

type C

type C struct {
	// contains filtered or unexported fields
}

func (*C) Coordinator

func (c *C) Coordinator(group string) (model.Broker, error)

func (*C) CoordinatorIsDown

func (c *C) CoordinatorIsDown(group string)

func (*C) Leader

func (c *C) Leader(topic string, partition int32) (model.Broker, error)

func (*C) LeaderIsDown

func (c *C) LeaderIsDown(topic string, partition int32)

func (*C) Partitions

func (c *C) Partitions(topic string) ([]int32, error)

type MultiError

type MultiError []error

func (*MultiError) Add

func (es *MultiError) Add(err error)

func (MultiError) Error

func (es MultiError) Error() string

type NewBrokerFunc

type NewBrokerFunc func(addr string) model.Broker