extproc

Documentation

Index

• type DefaultExternalProcess
  • func (s *DefaultExternalProcess) RequestBody(ctx context.Context, req *pb.ProcessingRequest_RequestBody, ...) (res *pb.ProcessingResponse, err error)
  • func (s *DefaultExternalProcess) RequestHeaders(ctx context.Context, req *pb.ProcessingRequest_RequestHeaders, ...) (res *pb.ProcessingResponse, err error)
  • func (s *DefaultExternalProcess) ResponseBody(ctx context.Context, req *pb.ProcessingRequest_ResponseBody, ...) (res *pb.ProcessingResponse, err error)
  • func (s *DefaultExternalProcess) ResponseHeaders(ctx context.Context, req *pb.ProcessingRequest_ResponseHeaders, ...) (res *pb.ProcessingResponse, err error)
• type ExternalProcess
• type Option
  • func WithHealthCheckServer(h healthpb.HealthServer) Option
• type Options
• type Server
  • func New(s *grpc.Server, ep ExternalProcess, opts ...Option) *Server
  • func (s *Server) Process(processServer pb.ExternalProcessor_ProcessServer) error
  • func (s *Server) Run(ctx context.Context, listener net.Listener)

Types

type DefaultExternalProcess

type DefaultExternalProcess struct{}

func (*DefaultExternalProcess) RequestBody

func (s *DefaultExternalProcess) RequestBody(ctx context.Context, req *pb.ProcessingRequest_RequestBody, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)

func (*DefaultExternalProcess) RequestHeaders

func (s *DefaultExternalProcess) RequestHeaders(ctx context.Context, req *pb.ProcessingRequest_RequestHeaders, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)

func (*DefaultExternalProcess) ResponseBody

func (s *DefaultExternalProcess) ResponseBody(ctx context.Context, req *pb.ProcessingRequest_ResponseBody, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)

func (*DefaultExternalProcess) ResponseHeaders

func (s *DefaultExternalProcess) ResponseHeaders(ctx context.Context, req *pb.ProcessingRequest_ResponseHeaders, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)

type ExternalProcess

type ExternalProcess interface {
	RequestHeaders(ctx context.Context, req *pb.ProcessingRequest_RequestHeaders, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)
	RequestBody(ctx context.Context, req *pb.ProcessingRequest_RequestBody, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)
	ResponseHeaders(ctx context.Context, req *pb.ProcessingRequest_ResponseHeaders, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)
	ResponseBody(ctx context.Context, req *pb.ProcessingRequest_ResponseBody, metadataContext *v3.Metadata) (res *pb.ProcessingResponse, err error)
}

type Option

type Option func(*Options)

func WithHealthCheckServer

func WithHealthCheckServer(h healthpb.HealthServer) Option

type Options

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

type Server

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

func New

func New(s *grpc.Server, ep ExternalProcess, opts ...Option) *Server

func (*Server) Process

func (s *Server) Process(processServer pb.ExternalProcessor_ProcessServer) error

func (*Server) Run

func (s *Server) Run(ctx context.Context, listener net.Listener)

Run runs the server until the context is canceled.