Documentation
¶
Index ¶
- Variables
- func RegisterDiscoverAPIServer(s *grpc.Server, srv DiscoverAPIServer)
- type DiscoverAPIClient
- type DiscoverAPIServer
- type DiscoverAPI_WatchClient
- type DiscoverAPI_WatchServer
- type Identity
- type UnimplementedDiscoverAPIServer
- type WatchRequest
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchResponse) GetApplication() *Identity
- func (x *WatchResponse) GetAvailable() bool
- func (*WatchResponse) ProtoMessage()
- func (x *WatchResponse) ProtoReflect() protoreflect.Message
- func (x *WatchResponse) Reset()
- func (x *WatchResponse) String() string
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.1
func RegisterDiscoverAPIServer(s *grpc.Server, srv DiscoverAPIServer)
Types ¶
type DiscoverAPIClient ¶ added in v0.2.1
type DiscoverAPIClient interface {
// Watch starts watching the server for updates to the availability of Dogma
// applications.
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.1
func NewDiscoverAPIClient(cc grpc.ClientConnInterface) DiscoverAPIClient
type DiscoverAPIServer ¶ added in v0.2.1
type DiscoverAPIServer interface {
// Watch starts watching the server for updates to the availability of Dogma
// applications.
Watch(*WatchRequest, DiscoverAPI_WatchServer) error
}
DiscoverAPIServer is the server API for DiscoverAPI service.
type DiscoverAPI_WatchClient ¶ added in v0.2.1
type DiscoverAPI_WatchClient interface {
Recv() (*WatchResponse, error)
grpc.ClientStream
}
type DiscoverAPI_WatchServer ¶ added in v0.2.1
type DiscoverAPI_WatchServer interface {
Send(*WatchResponse) error
grpc.ServerStream
}
type Identity ¶ added in v0.2.1
type Identity struct {
// Name is the application's unique name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Key is the application'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.
func (*Identity) Descriptor
deprecated
added in
v0.2.1
func (*Identity) ProtoMessage ¶ added in v0.2.1
func (*Identity) ProtoMessage()
func (*Identity) ProtoReflect ¶ added in v0.2.1
func (x *Identity) ProtoReflect() protoreflect.Message
type UnimplementedDiscoverAPIServer ¶ added in v0.2.1
type UnimplementedDiscoverAPIServer struct {
}
UnimplementedDiscoverAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedDiscoverAPIServer) Watch ¶ added in v0.2.1
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 {
// Application is the identity of the Dogma application that the
Application *Identity `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
// Available indicates whether the application should currently be considered
// available or not.
Available bool `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"`
// contains filtered or unexported fields
}
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetApplication ¶ added in v0.4.0
func (x *WatchResponse) GetApplication() *Identity
func (*WatchResponse) GetAvailable ¶ added in v0.3.0
func (x *WatchResponse) GetAvailable() bool
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.