grpcweb

Documentation

Index

• type BidiStream
• type CallOption
  • func CallContentSubtype(contentSubtype string) CallOption
  • func Header(h *metadata.MD) CallOption
  • func Trailer(t *metadata.MD) CallOption
• type ClientConn
  • func DialContext(host string, opts ...DialOption) (*ClientConn, error)
  • func (c *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, ...) error
  • func (c *ClientConn) NewBidiStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (BidiStream, error)
  • func (c *ClientConn) NewClientStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (ClientStream, error)
  • func (c *ClientConn) NewServerStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (ServerStream, error)
• type ClientStream
• type DialOption
  • func WithDefaultCallOptions(opts ...CallOption) DialOption
  • func WithInsecure() DialOption
  • func WithTransportCredentials(creds credentials.TransportCredentials) DialOption
• type ServerStream

Types

type BidiStream

type BidiStream interface {
	// Header returns the header metadata from the server, if there is any.
	// It blocks if the metadata is not ready to read.
	Header() (metadata.MD, error)
	// Trailer returns the trailer metadata from the server, if there is any.
	// It must only be called after stream.CloseAndReceive has returned, or
	// stream.Receive has returned a non-nil error (including io.EOF).
	Trailer() metadata.MD
	Send(ctx context.Context, req interface{}) error
	Receive(ctx context.Context, res interface{}) error
	CloseSend() error
}

type CallOption

type CallOption func(*callOptions)

func CallContentSubtype

func CallContentSubtype(contentSubtype string) CallOption

func Header

func Header(h *metadata.MD) CallOption

func Trailer

func Trailer(t *metadata.MD) CallOption

type ClientConn

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

func DialContext

func DialContext(host string, opts ...DialOption) (*ClientConn, error)

func (*ClientConn) Invoke

func (c *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, opts ...CallOption) error

func (*ClientConn) NewBidiStream

func (c *ClientConn) NewBidiStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (BidiStream, error)

func (*ClientConn) NewClientStream

func (c *ClientConn) NewClientStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (ClientStream, error)

func (*ClientConn) NewServerStream

func (c *ClientConn) NewServerStream(desc *grpc.StreamDesc, method string, opts ...CallOption) (ServerStream, error)

type ClientStream

type ClientStream interface {
	// Header returns the header metadata from the server, if there is any.
	// It blocks if the metadata is not ready to read.
	Header() (metadata.MD, error)
	// Trailer returns the trailer metadata from the server, if there is any.
	// It must only be called after stream.CloseAndReceive has returned, or
	// stream.Receive has returned a non-nil error (including io.EOF).
	Trailer() metadata.MD
	Send(ctx context.Context, req interface{}) error
	CloseAndReceive(ctx context.Context, res interface{}) error
}

type DialOption

type DialOption func(*dialOptions)

func WithDefaultCallOptions

func WithDefaultCallOptions(opts ...CallOption) DialOption

func WithInsecure

func WithInsecure() DialOption

func WithTransportCredentials

func WithTransportCredentials(creds credentials.TransportCredentials) DialOption

type ServerStream

type ServerStream interface {
	// Header returns the header metadata from the server, if there is any.
	// It blocks if the metadata is not ready to read.
	Header() (metadata.MD, error)
	// Trailer returns the trailer metadata from the server, if there is any.
	// It must only be called after stream.CloseAndReceive has returned, or
	// stream.Receive has returned a non-nil error (including io.EOF).
	Trailer() metadata.MD
	Send(ctx context.Context, req interface{}) error
	Receive(ctx context.Context, res interface{}) error
}