presencespec

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2020 License: MIT Imports: 9 Imported by: 0

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.

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL