model

Documentation

Index

• Constants
• type Broker
  • func FromProtoBufBroker(pb *pbTypes.Broker) *Broker
  • func (b *Broker) BrokerShardId() uint64
  • func (b *Broker) JoinShard(partition *Partition)
  • func (b *Broker) NodeHost() *dragonboat.NodeHost
  • func (b *Broker) SetBrokerShardId(brokerShardId uint64)
  • func (b *Broker) SetNodeHost(nh *dragonboat.NodeHost)
  • func (b *Broker) ShardForPartition(partition string) (uint64, bool)
  • func (b *Broker) ToProtoBuf() *pbTypes.Broker
• type Consumer
  • func FromProtoBufConsumer(pbConsumer *pbTypes.Consumer) *Consumer
  • func (c *Consumer) GetCurrentPartition() string
  • func (c *Consumer) IncPartitionIndex() int
  • func (c *Consumer) PartitionIndex() int
  • func (c *Consumer) SetPartitions(partitions []string)
  • func (c *Consumer) String() string
  • func (c *Consumer) ToProtoBuf() *pbTypes.Consumer
• type ConsumerGroup
  • func FromProtoBufConsumerGroup(pb *pbTypes.ConsumerGroup) *ConsumerGroup
  • func (c *ConsumerGroup) AddConsumer(consumerID string)
  • func (c *ConsumerGroup) RebalanceInProgress() bool
  • func (c *ConsumerGroup) SetRebalanceInProgress(inProgress bool)
  • func (c *ConsumerGroup) String() string
  • func (c *ConsumerGroup) ToProtoBuf() *pbTypes.ConsumerGroup
• type Message
  • func FromProtoBufMessage(pbMessage *pbTypes.Message) *Message
  • func (m *Message) String() string
  • func (m *Message) ToProtoBuf() *pbTypes.Message
• type Partition
  • func FromProtoBufPartition(pb *pbTypes.Partition) *Partition
  • func (m *Partition) ToProtoBuf() *pbTypes.Partition
• type ShardInfo
  • func FromProtoBufShardInfo(pb *pbTypes.ShardInfo) *ShardInfo
  • func (s *ShardInfo) ToProtoBuf() *pbTypes.ShardInfo
• type ShardType
• type Topic
  • func FromProtoBufTopic(pb *pbTypes.Topic) *Topic
  • func (t *Topic) String() string
  • func (t *Topic) ToProtoBuf() *pbTypes.Topic

Constants

const DefaultPartition = "default"

Types

type Broker

type Broker struct {
	ID uint64

	RaftAddress      string
	ReachGrpcAddress string
	ReachHttpAddress string

	StartMsgFSM chan *Partition
	// contains filtered or unexported fields
}

func FromProtoBufBroker

func FromProtoBufBroker(pb *pbTypes.Broker) *Broker

func (*Broker) BrokerShardId

func (b *Broker) BrokerShardId() uint64

func (*Broker) JoinShard

func (b *Broker) JoinShard(partition *Partition)

func (*Broker) NodeHost

func (b *Broker) NodeHost() *dragonboat.NodeHost

func (*Broker) SetBrokerShardId

func (b *Broker) SetBrokerShardId(brokerShardId uint64)

func (*Broker) SetNodeHost

func (b *Broker) SetNodeHost(nh *dragonboat.NodeHost)

func (*Broker) ShardForPartition

func (b *Broker) ShardForPartition(partition string) (uint64, bool)

func (*Broker) ToProtoBuf

func (b *Broker) ToProtoBuf() *pbTypes.Broker

type Consumer

type Consumer struct {
	ID            string
	Partitions    []string
	ConsumerGroup string
	Topics        []string
	IsActive      bool

	LastHealthCheckAt int64
	// contains filtered or unexported fields
}

func FromProtoBufConsumer

func FromProtoBufConsumer(pbConsumer *pbTypes.Consumer) *Consumer

func (*Consumer) GetCurrentPartition

func (c *Consumer) GetCurrentPartition() string

func (*Consumer) IncPartitionIndex

func (c *Consumer) IncPartitionIndex() int

func (*Consumer) PartitionIndex

func (c *Consumer) PartitionIndex() int

func (*Consumer) SetPartitions

func (c *Consumer) SetPartitions(partitions []string)

func (*Consumer) String

func (c *Consumer) String() string

func (*Consumer) ToProtoBuf

func (c *Consumer) ToProtoBuf() *pbTypes.Consumer

type ConsumerGroup

type ConsumerGroup struct {
	ID        string
	Topics    map[string]bool
	Consumers map[string]bool
	// contains filtered or unexported fields
}

func FromProtoBufConsumerGroup

func FromProtoBufConsumerGroup(pb *pbTypes.ConsumerGroup) *ConsumerGroup

func (*ConsumerGroup) AddConsumer

func (c *ConsumerGroup) AddConsumer(consumerID string)

func (*ConsumerGroup) RebalanceInProgress

func (c *ConsumerGroup) RebalanceInProgress() bool

func (*ConsumerGroup) SetRebalanceInProgress

func (c *ConsumerGroup) SetRebalanceInProgress(inProgress bool)

func (*ConsumerGroup) String

func (c *ConsumerGroup) String() string

func (*ConsumerGroup) ToProtoBuf

func (c *ConsumerGroup) ToProtoBuf() *pbTypes.ConsumerGroup

type Message

type Message struct {
	Topic        string
	PartitionKey string
	PartitionID  string
	Data         []byte
	ID           []byte
}

func FromProtoBufMessage

func FromProtoBufMessage(pbMessage *pbTypes.Message) *Message

func (*Message) String

func (m *Message) String() string

func (*Message) ToProtoBuf

func (m *Message) ToProtoBuf() *pbTypes.Message

type Partition

type Partition struct {
	ID        string
	TopicName string
	ShardID   uint64
	Members   map[uint64]string
}

func FromProtoBufPartition

func FromProtoBufPartition(pb *pbTypes.Partition) *Partition

func (*Partition) ToProtoBuf

func (m *Partition) ToProtoBuf() *pbTypes.Partition

type ShardInfo

type ShardInfo struct {
	ShardType   ShardType
	ShardID     uint64
	Topic       string
	PartitionID string
	Brokers     []*Broker
}

func FromProtoBufShardInfo

func FromProtoBufShardInfo(pb *pbTypes.ShardInfo) *ShardInfo

func (*ShardInfo) ToProtoBuf

func (s *ShardInfo) ToProtoBuf() *pbTypes.ShardInfo

type ShardType

type ShardType string

const (
	ShardTypeBrokers    ShardType = "BROKERS"
	ShardTypePartitions ShardType = "PARTITIONS"
)

type Topic

type Topic struct {
	Name               string
	NumberOfPartitions uint64
}

func FromProtoBufTopic

func FromProtoBufTopic(pb *pbTypes.Topic) *Topic

func (*Topic) String

func (t *Topic) String() string

func (*Topic) ToProtoBuf

func (t *Topic) ToProtoBuf() *pbTypes.Topic