kstream

Documentation

Index

• Constants
• Variables
• func InitStreamStores()
• type Callback
• type ModelType
• type ProxyStream
  • func InitStream(client pb.StreamClient, model ModelType, callback Callback) *ProxyStream
  • func (p *ProxyStream) DelStream()
  • func (p *ProxyStream) GetStream(client pb.StreamClient) pb.Stream_CellClient
  • func (p *ProxyStream) PushChan(info *pb.CellReq)

Constants

const (
	MsgConnectReq          = 101
	MsgNodeHeartBeatResp   = 1001
	MsgTestStepUpdateResp  = 1002
	MsgWorkerHeartBeatResp = 1003
)

Variables

var StreamStore *stores

Functions

func InitStreamStores

func InitStreamStores()

Types

type Callback

type Callback func(reply *pb.CellResp)

type ModelType

type ModelType int

const (
	ModelTypeOnlyWrite ModelType = iota + 1
	ModelTypeOnlyRead
	ModelTypeBoth
)

type ProxyStream

type ProxyStream struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func InitStream

func InitStream(client pb.StreamClient, model ModelType, callback Callback) *ProxyStream

func (*ProxyStream) DelStream

func (p *ProxyStream) DelStream()

func (*ProxyStream) GetStream

func (p *ProxyStream) GetStream(client pb.StreamClient) pb.Stream_CellClient

func (*ProxyStream) PushChan

func (p *ProxyStream) PushChan(info *pb.CellReq)