internal

package
v0.0.0-...-1ed9f32 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 30, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ResponseClientInput

type ResponseClientInput struct {
	URL    *url.URL
	Method string
	Header http.Header
	Body   []byte
}

type ResponseGRPCClient

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

func (*ResponseGRPCClient) Modify

func (m *ResponseGRPCClient) Modify(in *ResponseClientInput) (rHeader http.Header, rBody []byte, rErr error)

type ResponseGRPCServer

type ResponseGRPCServer struct {
	Impl shared.Response
	plugins.UnimplementedResponseServer
}

func (*ResponseGRPCServer) Modify

type ResponsePlugin

type ResponsePlugin struct {
	plugin.Plugin
	Impl shared.Response
}

func (*ResponsePlugin) GRPCClient

func (p *ResponsePlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*ResponsePlugin) GRPCServer

func (p *ResponsePlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type TransportGRPCClient

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

func (*TransportGRPCClient) Transport

func (m *TransportGRPCClient) Transport(header http.Header, u *url.URL) (rHeader http.Header, rUrl *url.URL, rErr error)

type TransportGRPCServer

type TransportGRPCServer struct {
	Impl shared.Transport
	plugins.UnimplementedTransportServer
}

func (*TransportGRPCServer) Transport

func (m *TransportGRPCServer) Transport(ctx context.Context, inf *plugins.Interface) (*plugins.Reply, error)

type TransportPlugin

type TransportPlugin struct {
	plugin.Plugin
	Impl shared.Transport
}

func (*TransportPlugin) GRPCClient

func (p *TransportPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*TransportPlugin) GRPCServer

func (p *TransportPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL