sockets

type CallOption interface {
	grpc.CallOption
	Lava()
}

type CallOptions struct {
	grpc.EmptyCallOption
	// Headers is a slice of metadata pointers which should all be set when
	// response header metadata is received.
	Headers []*metadata.MD
	// Trailers is a slice of metadata pointers which should all be set when
	// response trailer metadata is received.
	Trailers []*metadata.MD
	// Peer is a slice of peer pointers which should all be set when the
	// remote peer is known.
	Peer []*peer.Peer
	// Creds are per-RPC credentials to use for a call.
	Creds credentials.PerRPCCredentials
	// MaxRecv is the maximum number of bytes to receive for a single message
	// in a call.
	MaxRecv int
	// MaxSend is the maximum number of bytes to send for a single message in
	// a call.
	MaxSend int

	ContentSubtype string

	CompressorType string

	Codec encoding.Codec
}

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

type ErrPayload struct {
	payload.Payload
	Err chan error
}

type Metadata struct {
	Version   string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Service   string            `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Method    string            `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Trace     string            `protobuf:"bytes,4,opt,name=trace,proto3" json:"trace,omitempty"`
	Address   string            `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	RequestId string            `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Header    map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Request struct {
	Method      string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	ContentType string            `protobuf:"bytes,2,opt,name=contentType,proto3" json:"contentType,omitempty"`
	RequestId   string            `protobuf:"bytes,3,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Headers     map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Response struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// 持续时间(ms)
	Duration int32             `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	Headers  map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Server struct {
	ServerStreams bool
	ClientStreams bool
	// contains filtered or unexported fields
}

type StreamHandler = grpc.StreamHandler

type UnaryHandler = func(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error)