Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_github_com_dogmatiq_interopspec_presencespec_presenceapi_proto protoreflect.FileDescriptor
Functions ¶
func RegisterPresenceAPIServer ¶
func RegisterPresenceAPIServer(s *grpc.Server, srv PresenceAPIServer)
Types ¶
type PresenceAPIClient ¶
type PresenceAPIClient interface {
// Watch starts watching the server until it goes offline.
//
// The server MUST NOT send any responses.
//
// The caller SHOULD await a response (which is never sent) until an error
// occurs, indicating that the server has gone offline.
Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (PresenceAPI_WatchClient, error)
}
PresenceAPIClient is the client API for PresenceAPI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPresenceAPIClient ¶
func NewPresenceAPIClient(cc grpc.ClientConnInterface) PresenceAPIClient
type PresenceAPIServer ¶
type PresenceAPIServer interface {
// Watch starts watching the server until it goes offline.
//
// The server MUST NOT send any responses.
//
// The caller SHOULD await a response (which is never sent) until an error
// occurs, indicating that the server has gone offline.
Watch(*WatchRequest, PresenceAPI_WatchServer) error
}
PresenceAPIServer is the server API for PresenceAPI service.
type PresenceAPI_WatchClient ¶
type PresenceAPI_WatchClient interface {
Recv() (*WatchResponse, error)
grpc.ClientStream
}
type PresenceAPI_WatchServer ¶
type PresenceAPI_WatchServer interface {
Send(*WatchResponse) error
grpc.ServerStream
}
type UnimplementedPresenceAPIServer ¶
type UnimplementedPresenceAPIServer struct {
}
UnimplementedPresenceAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedPresenceAPIServer) Watch ¶
func (*UnimplementedPresenceAPIServer) Watch(*WatchRequest, PresenceAPI_WatchServer) error
type WatchRequest ¶
type WatchRequest struct {
// contains filtered or unexported fields
}
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
type WatchResponse ¶
type WatchResponse struct {
// contains filtered or unexported fields
}
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string
Click to show internal directories.
Click to hide internal directories.