transport

Documentation

Index

• type ClientStreamTransport
  • func NewClientStream(host, endpoint string) (ClientStreamTransport, error)
• type ConnectOptions
• type UnaryTransport
  • func NewUnary(host string, opts *ConnectOptions) UnaryTransport

Types

type ClientStreamTransport

type ClientStreamTransport interface {
	Send(ctx context.Context, body io.Reader) error
	Receive(ctx context.Context) (io.ReadCloser, error)

	// CloseSend sends a close signal to the server.
	CloseSend() error

	// Close closes the connection.
	Close() error
}

func NewClientStream

func NewClientStream(host, endpoint string) (ClientStreamTransport, error)

type ConnectOptions

type ConnectOptions struct {
	Insecure bool
	Headers  http.Header
}

type UnaryTransport

type UnaryTransport interface {
	Send(ctx context.Context, endpoint, contentType string, body io.Reader) (io.ReadCloser, error)
	Close() error
}

func NewUnary

func NewUnary(host string, opts *ConnectOptions) UnaryTransport