Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
- type APIClient
- type APIServer
- type API_ListenClient
- type API_ListenServer
- type ListenRequest
- func (*ListenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenRequest) GetChannel() string
- func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ListenRequest) ProtoMessage()
- func (x *ListenRequest) ProtoReflect() protoreflect.Message
- func (x *ListenRequest) Reset()
- func (x *ListenRequest) String() string
- type ListenResponse
- func (*ListenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListenResponse) GetExtra() string
- func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ListenResponse) ProtoMessage()
- func (x *ListenResponse) ProtoReflect() protoreflect.Message
- func (x *ListenResponse) Reset()
- func (x *ListenResponse) String() string
- type UnimplementedAPIServer
- type UnsafeAPIServer
Constants ¶
const (
API_Listen_FullMethodName = "/proxy.API/Listen"
)
Variables ¶
var API_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proxy.API", HandlerType: (*APIServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Listen", Handler: _API_Listen_Handler, ServerStreams: true, }, }, Metadata: "proxy/proxy.proto", }
API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proxy_proxy_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAPIServer ¶
func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
Types ¶
type APIClient ¶
type APIClient interface { // Listen streams database events. // It signals that it is internally set up by sending an initial empty ListenResponse. Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc grpc.ClientConnInterface) APIClient
type APIServer ¶
type APIServer interface { // Listen streams database events. // It signals that it is internally set up by sending an initial empty ListenResponse. Listen(*ListenRequest, API_ListenServer) error // contains filtered or unexported methods }
APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility
type API_ListenClient ¶
type API_ListenClient interface { Recv() (*ListenResponse, error) grpc.ClientStream }
type API_ListenServer ¶
type API_ListenServer interface { Send(*ListenResponse) error grpc.ServerStream }
type ListenRequest ¶
type ListenRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*ListenRequest) Descriptor
deprecated
func (*ListenRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.
func (*ListenRequest) GetChannel ¶
func (x *ListenRequest) GetChannel() string
func (*ListenRequest) MarshalLogObject ¶
func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ListenRequest) ProtoMessage ¶
func (*ListenRequest) ProtoMessage()
func (*ListenRequest) ProtoReflect ¶ added in v2.7.0
func (x *ListenRequest) ProtoReflect() protoreflect.Message
func (*ListenRequest) Reset ¶
func (x *ListenRequest) Reset()
func (*ListenRequest) String ¶
func (x *ListenRequest) String() string
type ListenResponse ¶
type ListenResponse struct { Extra string `protobuf:"bytes,1,opt,name=extra,proto3" json:"extra,omitempty"` // contains filtered or unexported fields }
func (*ListenResponse) Descriptor
deprecated
func (*ListenResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.
func (*ListenResponse) GetExtra ¶
func (x *ListenResponse) GetExtra() string
func (*ListenResponse) MarshalLogObject ¶
func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ListenResponse) ProtoMessage ¶
func (*ListenResponse) ProtoMessage()
func (*ListenResponse) ProtoReflect ¶ added in v2.7.0
func (x *ListenResponse) ProtoReflect() protoreflect.Message
func (*ListenResponse) Reset ¶
func (x *ListenResponse) Reset()
func (*ListenResponse) String ¶
func (x *ListenResponse) String() string
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer must be embedded to have forward compatible implementations.
func (UnimplementedAPIServer) Listen ¶
func (UnimplementedAPIServer) Listen(*ListenRequest, API_ListenServer) error
type UnsafeAPIServer ¶ added in v2.7.0
type UnsafeAPIServer interface {
// contains filtered or unexported methods
}
UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.