partitioner

Documentation

Index

• type PartitionMethod
  • func GetPartitionMethod(name string) PartitionMethod
• type Partitioner
  • func New(shutdownHandler shutdown.ShutdownHandler, ...) Partitioner
  • func (f *Partitioner) Start()

Types

type PartitionMethod

type PartitionMethod int

const (
	PART_METHOD_NONE       PartitionMethod = iota // No partitioning
	PART_METHOD_TABLENAME                         // Table name based partitioning
	PART_METHOD_TXN                               // Transaction based partitioning
	PART_METHOD_TXN_BUCKET                        // Transaction based partitioning with buckets
)

func GetPartitionMethod

func GetPartitionMethod(name string) PartitionMethod

type Partitioner

type Partitioner struct {
	OutputChan chan *replication.WalMessage
	// contains filtered or unexported fields
}

func New

func New(shutdownHandler shutdown.ShutdownHandler,
	inputChan <-chan *replication.WalMessage,
	statsChan chan stats.Stat,
	partMethod PartitionMethod,
	buckets int,
) Partitioner

func (*Partitioner) Start

func (f *Partitioner) Start()