rpc

type Call interface {
	ID() uint64
}

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

type CallIn struct {
	CallBase
	ParentCallAccessor
	// contains filtered or unexported fields
}

type CallOut struct {
	CallBase
	// contains filtered or unexported fields
}

type Caller interface {
	CallUnary(ctx context.Context, method string, req proto.Message, res proto.Message) error
	CallStreaming(ctx context.Context, method string, req proto.Message, res interface{}) error
}

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

type Dialer interface {
	Dial(context.Context, Dispatcher) (Transport, error)
}

type Dispatcher interface {
	Dispatch(*CallIn, func())
}

type ErrorCoder interface {
	error
	ErrorCode() int32
}

type HTTPServer struct {
	*ServiceDispatcher
}

type ParentCallAccessor interface {
	ParentCallIn() *CallIn
	ParentCallOut() *CallOut
}

type RWDialer struct {
	Logger          *zap.Logger
	ReadWriter      io.ReadWriter
	MaxMessageBytes int
}

type RWFDialer struct {
	Logger           *zap.Logger
	ReadWriteFlusher ReadWriteFlusher
}

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

type ReadWriteFlusher interface {
	io.ReadWriter
	Flush() error
}

type ResponseFunc func() error

type ResponseType int

type SendFunc func(context.Context, *pb.Call) error

type Server struct {
	*ServiceDispatcher
	// contains filtered or unexported fields
}

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

type ServiceRegistry interface {
	RegisterMethod(name string, method interface{})
}

type Transport interface {
	Call(*CallOut, ResponseFunc) error
	Listen() error
}