presencespec

package
v0.2.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_discoverspec_discoverapi_proto protoreflect.FileDescriptor

Functions

func RegisterDiscoverAPIServer added in v0.2.0

func RegisterDiscoverAPIServer(s *grpc.Server, srv DiscoverAPIServer)

Types

type DiscoverAPIClient added in v0.2.0

type DiscoverAPIClient interface {
	// ListApplicationIdentities returns the identity of all applications.
	ListApplicationIdentities(ctx context.Context, in *ListApplicationIdentitiesRequest, opts ...grpc.CallOption) (*ListApplicationIdentitiesResponse, error)
	// 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) (DiscoverAPI_WatchClient, error)
}

DiscoverAPIClient is the client API for DiscoverAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscoverAPIClient added in v0.2.0

func NewDiscoverAPIClient(cc grpc.ClientConnInterface) DiscoverAPIClient

type DiscoverAPIServer added in v0.2.0

type DiscoverAPIServer interface {
	// ListApplicationIdentities returns the identity of all applications.
	ListApplicationIdentities(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)
	// 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, DiscoverAPI_WatchServer) error
}

DiscoverAPIServer is the server API for DiscoverAPI service.

type DiscoverAPI_WatchClient added in v0.2.0

type DiscoverAPI_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type DiscoverAPI_WatchServer added in v0.2.0

type DiscoverAPI_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type Identity added in v0.2.0

type Identity struct {

	// Name is the entity's unique name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Key is the entity's immutable, unique key.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Identity represents the identity of an application or handler.

func (*Identity) Descriptor deprecated added in v0.2.0

func (*Identity) Descriptor() ([]byte, []int)

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetKey added in v0.2.0

func (x *Identity) GetKey() string

func (*Identity) GetName added in v0.2.0

func (x *Identity) GetName() string

func (*Identity) ProtoMessage added in v0.2.0

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect added in v0.2.0

func (x *Identity) ProtoReflect() protoreflect.Message

func (*Identity) Reset added in v0.2.0

func (x *Identity) Reset()

func (*Identity) String added in v0.2.0

func (x *Identity) String() string

type ListApplicationIdentitiesRequest added in v0.2.0

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

func (*ListApplicationIdentitiesRequest) Descriptor deprecated added in v0.2.0

func (*ListApplicationIdentitiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListApplicationIdentitiesRequest.ProtoReflect.Descriptor instead.

func (*ListApplicationIdentitiesRequest) ProtoMessage added in v0.2.0

func (*ListApplicationIdentitiesRequest) ProtoMessage()

func (*ListApplicationIdentitiesRequest) ProtoReflect added in v0.2.0

func (*ListApplicationIdentitiesRequest) Reset added in v0.2.0

func (*ListApplicationIdentitiesRequest) String added in v0.2.0

type ListApplicationIdentitiesResponse added in v0.2.0

type ListApplicationIdentitiesResponse struct {
	Identities []*Identity `protobuf:"bytes,1,rep,name=identities,proto3" json:"identities,omitempty"`
	// contains filtered or unexported fields
}

func (*ListApplicationIdentitiesResponse) Descriptor deprecated added in v0.2.0

func (*ListApplicationIdentitiesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListApplicationIdentitiesResponse.ProtoReflect.Descriptor instead.

func (*ListApplicationIdentitiesResponse) GetIdentities added in v0.2.0

func (x *ListApplicationIdentitiesResponse) GetIdentities() []*Identity

func (*ListApplicationIdentitiesResponse) ProtoMessage added in v0.2.0

func (*ListApplicationIdentitiesResponse) ProtoMessage()

func (*ListApplicationIdentitiesResponse) ProtoReflect added in v0.2.0

func (*ListApplicationIdentitiesResponse) Reset added in v0.2.0

func (*ListApplicationIdentitiesResponse) String added in v0.2.0

type UnimplementedDiscoverAPIServer added in v0.2.0

type UnimplementedDiscoverAPIServer struct {
}

UnimplementedDiscoverAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiscoverAPIServer) ListApplicationIdentities added in v0.2.0

func (*UnimplementedDiscoverAPIServer) Watch added in v0.2.0

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