fifo

Documentation

Overview

some algorism

the fifo struct Note: the one fifo's max index cannot exceed the range of int32

the zk initialization

Index

• func CloseZkConn()
• func EstablishZkConn(hosts []string) error
• type DistributedFIFO
  • func NewFifo(path string, data []byte, prefix string) *DistributedFIFO
  • func (this *DistributedFIFO) Poll() (res []byte)
  • func (this *DistributedFIFO) Put(data []byte)
  • func (this *DistributedFIFO) Size() (int, error)

Functions

func CloseZkConn

func CloseZkConn()

func EstablishZkConn

func EstablishZkConn(hosts []string) error

Types

type DistributedFIFO

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

func NewFifo

func NewFifo(path string, data []byte, prefix string) *DistributedFIFO

create the fifo

func (*DistributedFIFO) Poll

func (this *DistributedFIFO) Poll() (res []byte)

get one data from znodes and delete the chosen znode

func (*DistributedFIFO) Put

func (this *DistributedFIFO) Put(data []byte)

sequentially create a zonde

func (*DistributedFIFO) Size

func (this *DistributedFIFO) Size() (int, error)

get the size of the queue