bistream

README

介绍

这是一个通用的基于grpc的双向流.

1. 依赖 registry.Service
2. 不依赖业务实现, 业务实现是可以定制的
   1. 握手 handler
   2. 各种 rpc handler

Documentation

Index

• Constants
• type Manager
  • func NewManager(rs *registry.Service, hr *registry.HandlerRegistry) *Manager
  • func (m *Manager) Start()
  • func (m *Manager) Stop()

Constants

const (
	RpcTypeOneway          = 0
	RpcTypeReq             = 1
	RpcTypeResp            = 2
	RpcTypeClientHandShake = 3
	RpcTypeServerHandShake = 4
	BizTypeNotFound        = -1
	BizTypeError           = -2
)

Types

type Manager

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

func NewManager

func NewManager(rs *registry.Service, hr *registry.HandlerRegistry) *Manager

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) Stop

func (m *Manager) Stop()