grpc_context

type GrpcFilter interface {
	DoGrpcFilter(ctx IGrpcContext, next eocontext.IChain) (err error)
}

type IGrpcContext interface {
	eocontext.EoContext

	// Request 获取原始请求
	Request() IRequest
	// Proxy 获取待转发请求
	Proxy() IRequest
	// Response 获取服务端响应内容
	Response() IResponse

	// EnableTls 是否开启tls认证
	EnableTls(bool)
	// InsecureCertificateVerify 是否跳过证书检查
	InsecureCertificateVerify(bool)
	// Invoke grpc调用
	Invoke(node eocontext.INode, timeout time.Duration) error
	FastFinish() error
}

type IHeader interface {
	IHeaderReader
	IHeaderWriter
}

type IHeaderReader interface {
	Get(key string) string
	Headers()
}

type IHeaderWriter interface {
	Set(key string, value string)
}

type IMessageDescriptor interface {
}

type IRequest interface {
	Headers() metadata.MD
	Host() string
	SetHost(string)
	Service() string
	SetService(string)
	Method() string
	SetMethod(string)
	FullMethodName() string
	RealIP() string
	ForwardIP() string
	// Message 获取原始请求内容，在grpc协议需要转其他协议时使用
	Message(*desc.MessageDescriptor) *dynamic.Message
}

type IResponse interface {
	Headers() metadata.MD
	Message() *dynamic.Message
	Trailer() metadata.MD
	Write(msg *dynamic.Message)
	SetErr(err error)
	Error() error
}

type ITrailer interface {
	IHeaderReader
	IHeaderWriter
}