receiver

Documentation

Index

• type ReceiveChannel
  • func NewReceiveChannel(name string, leader string, offset uint64) *ReceiveChannel
  • func (rc *ReceiveChannel) GetChannel() (chan []byte, error)

Types

type ReceiveChannel

type ReceiveChannel struct {
	Ch chan []byte

	Leader string
	// contains filtered or unexported fields
}

func NewReceiveChannel

func NewReceiveChannel(name string, leader string, offset uint64) *ReceiveChannel

func (*ReceiveChannel) GetChannel

func (rc *ReceiveChannel) GetChannel() (chan []byte, error)

Not thread safe