proxy

type AuthHeaders interface {
	AuthHeaders(context.Context, *http.Request) (map[string]string, error)
}

type AuthHeadersFunc func(context.Context, *http.Request) (map[string]string, error)

type Codec interface {
	ToProto(body []byte, msg protoreflect.Message) error
	FromProto(msg protoreflect.Message) ([]byte, error)
}

type GRPCMethodConfig struct {
	AuthHeaders AuthHeaders
	Invoker     Invoker
	Method      protoreflect.MethodDescriptor
}

type Invoker interface {
	// Invoke is desined for gRPC ClientConn.Invoke, the two interfaces should
	// be protos...
	Invoke(context.Context, string, interface{}, interface{}, ...grpc.CallOption) error
}

type Router struct {
	ForwardResponseHeaders map[string]bool
	ForwardRequestHeaders  map[string]bool
	Codec                  Codec
	// contains filtered or unexported fields
}