grpcweb

Documentation

Index

• type BidiStream
• type CallOption
  • func ForceCodec(codec encoding.Codec) 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 {
	Send(ctx context.Context, req interface{}) error
	Receive(ctx context.Context, res interface{}) error
	CloseSend() error
}

type CallOption

type CallOption func(*callOptions)

func ForceCodec

func ForceCodec(codec encoding.Codec) 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 {
	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 {
	Send(ctx context.Context, req interface{}) error
	Receive(ctx context.Context, res interface{}) error
}