transport

Documentation

Index

• func NewClientContext(ctx context.Context, tr Transporter) context.Context
• func NewServerContext(ctx context.Context, tr Transporter) context.Context
• type EndpointRegister
• type Header
• type Kind
  • func (k Kind) String() string
• type Server
• type Transporter
  • func FromClientContext(ctx context.Context) (tr Transporter, ok bool)
  • func FromServerContext(ctx context.Context) (tr Transporter, ok bool)

Functions

func NewClientContext

func NewClientContext(ctx context.Context, tr Transporter) context.Context

func NewServerContext

func NewServerContext(ctx context.Context, tr Transporter) context.Context

Types

type EndpointRegister

type EndpointRegister interface {
	Endpoint() (*url.URL, error)
}

EndpointRegister is registry endpoint.

type Header

type Header interface {
	Get(key string) string
	Set(key, value string)
	Add(key, value string)
	Keys() []string
	Values(key string) []string
}

Header is the storage medium used by a Header.

type Kind

type Kind string // Kind defines the transport type

const (
	KindGRPC Kind = "grpc"
	KindHTTP Kind = "http"
)

func (Kind) String

func (k Kind) String() string

type Server

type Server interface {
	Start(context.Context) error
	Stop(context.Context) error
}

Server is transport server.

type Transporter

type Transporter interface {
	// Kind transporter
	// grpc
	// http
	Kind() Kind
	// Endpoint returns server/client endpoint
	Endpoint() string
	// Operation Service full method selector generated by protobuf, like /hello.Greeter/SayHello
	Operation() string
	// RequestHeader returns the transport request header
	// grpc: [metadata.MD]
	// http: [http.Header]
	RequestHeader() Header
	// ReplyHeader returns the transport reply/response header
	// grpc: [metadata.MD]
	// http: [http.Header]
	ReplyHeader() Header
}

Transporter is transport context value interface.

func FromClientContext

func FromClientContext(ctx context.Context) (tr Transporter, ok bool)

func FromServerContext

func FromServerContext(ctx context.Context) (tr Transporter, ok bool)