Documentation
¶
Index ¶
- Variables
- func RegisterDiscoverAPIServer(s *grpc.Server, srv DiscoverAPIServer)
- type DiscoverAPIClient
- type DiscoverAPIServer
- type DiscoverAPI_WatchClient
- type DiscoverAPI_WatchServer
- type Identity
- type ListApplicationIdentitiesRequest
- func (*ListApplicationIdentitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (*ListApplicationIdentitiesRequest) ProtoMessage()
- func (x *ListApplicationIdentitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ListApplicationIdentitiesRequest) Reset()
- func (x *ListApplicationIdentitiesRequest) String() string
- type ListApplicationIdentitiesResponse
- func (*ListApplicationIdentitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListApplicationIdentitiesResponse) GetIdentities() []*Identity
- func (*ListApplicationIdentitiesResponse) ProtoMessage()
- func (x *ListApplicationIdentitiesResponse) ProtoReflect() protoreflect.Message
- func (x *ListApplicationIdentitiesResponse) Reset()
- func (x *ListApplicationIdentitiesResponse) String() string
- type UnimplementedDiscoverAPIServer
- type WatchRequest
- type WatchResponse
Constants ¶
This section is empty.
Variables ¶
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) ProtoMessage ¶ added in v0.2.0
func (*Identity) ProtoMessage()
func (*Identity) ProtoReflect ¶ added in v0.2.0
func (x *Identity) ProtoReflect() protoreflect.Message
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 (x *ListApplicationIdentitiesRequest) ProtoReflect() protoreflect.Message
func (*ListApplicationIdentitiesRequest) Reset ¶ added in v0.2.0
func (x *ListApplicationIdentitiesRequest) Reset()
func (*ListApplicationIdentitiesRequest) String ¶ added in v0.2.0
func (x *ListApplicationIdentitiesRequest) String() string
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 (x *ListApplicationIdentitiesResponse) ProtoReflect() protoreflect.Message
func (*ListApplicationIdentitiesResponse) Reset ¶ added in v0.2.0
func (x *ListApplicationIdentitiesResponse) Reset()
func (*ListApplicationIdentitiesResponse) String ¶ added in v0.2.0
func (x *ListApplicationIdentitiesResponse) String() string
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) ListApplicationIdentities(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)
func (*UnimplementedDiscoverAPIServer) Watch ¶ added in v0.2.0
func (*UnimplementedDiscoverAPIServer) Watch(*WatchRequest, DiscoverAPI_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