discoverspec

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2020 License: MIT Imports: 9 Imported by: 2

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.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) Descriptor() ([]byte, []int)

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetKey added in v0.2.1

func (x *Identity) GetKey() string

func (*Identity) GetName added in v0.2.1

func (x *Identity) GetName() string

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

func (*Identity) Reset added in v0.2.1

func (x *Identity) Reset()

func (*Identity) String added in v0.2.1

func (x *Identity) String() string

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

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

Jump to

Keyboard shortcuts

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