Documentation
¶
Index ¶
- Variables
- func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
- type Application
- func (*Application) Descriptor() ([]byte, []int)deprecated
- func (x *Application) GetHandlers() []*Handler
- func (x *Application) GetIdentity() *Identity
- func (x *Application) GetMessages() []*NameRole
- func (x *Application) GetTypeName() string
- func (*Application) ProtoMessage()
- func (x *Application) ProtoReflect() protoreflect.Message
- func (x *Application) Reset()
- func (x *Application) String() string
- type ConfigClient
- type ConfigServer
- type Config_WatchClient
- type Config_WatchServer
- type Handler
- func (*Handler) Descriptor() ([]byte, []int)deprecated
- func (x *Handler) GetConsumed() []uint32
- func (x *Handler) GetIdentity() *Identity
- func (x *Handler) GetProduced() []uint32
- func (x *Handler) GetType() HandlerType
- func (x *Handler) GetTypeName() string
- func (*Handler) ProtoMessage()
- func (x *Handler) ProtoReflect() protoreflect.Message
- func (x *Handler) Reset()
- func (x *Handler) String() string
- type HandlerType
- func (HandlerType) Descriptor() protoreflect.EnumDescriptor
- func (x HandlerType) Enum() *HandlerType
- func (HandlerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x HandlerType) Number() protoreflect.EnumNumber
- func (x HandlerType) String() string
- func (HandlerType) Type() protoreflect.EnumType
- 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 ListApplicationsRequest
- type ListApplicationsResponse
- func (*ListApplicationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListApplicationsResponse) GetApplications() []*Application
- func (*ListApplicationsResponse) ProtoMessage()
- func (x *ListApplicationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListApplicationsResponse) Reset()
- func (x *ListApplicationsResponse) String() string
- type MessageRole
- func (MessageRole) Descriptor() protoreflect.EnumDescriptor
- func (x MessageRole) Enum() *MessageRole
- func (MessageRole) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageRole) Number() protoreflect.EnumNumber
- func (x MessageRole) String() string
- func (MessageRole) Type() protoreflect.EnumType
- type NameRole
- type UnimplementedConfigServer
- func (*UnimplementedConfigServer) ListApplicationIdentities(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)
- func (*UnimplementedConfigServer) ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)
- func (*UnimplementedConfigServer) Watch(*WatchRequest, Config_WatchServer) error
- type WatchRequest
- type WatchResponse
Constants ¶
This section is empty.
Variables ¶
var ( MessageRole_name = map[int32]string{ 0: "UNKNOWN_MESSAGE_ROLE", 1: "COMMAND", 2: "EVENT", 3: "TIMEOUT", } MessageRole_value = map[string]int32{ "UNKNOWN_MESSAGE_ROLE": 0, "COMMAND": 1, "EVENT": 2, "TIMEOUT": 3, } )
Enum value maps for MessageRole.
var ( HandlerType_name = map[int32]string{ 0: "UNKNOWN_HANDLER_TYPE", 1: "AGGREGATE", 2: "PROCESS", 3: "INTEGRATION", 4: "PROJECTION", } HandlerType_value = map[string]int32{ "UNKNOWN_HANDLER_TYPE": 0, "AGGREGATE": 1, "PROCESS": 2, "INTEGRATION": 3, "PROJECTION": 4, } )
Enum value maps for HandlerType.
var File_api_internal_pb_service_proto protoreflect.FileDescriptor
var File_api_internal_pb_types_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConfigServer ¶
func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
Types ¶
type Application ¶
type Application struct {
// Identity is the application's identity.
Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// TypeName is the fully-qualified name of the Go type used to implement the
// application.
TypeName string `protobuf:"bytes,2,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
// Messages is an ordered-sequence of message name / role pairs.
//
// This directly correlates to the configkit.Application.MessageNames().Roles
// value. The produced/consumed message names are not encoded directly in the
// application, but rather rebuilt from the handlers when the application is
// unmarshaled.
Messages []*NameRole `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
// Handlers is the set of handlers within the application.
Handlers []*Handler `protobuf:"bytes,4,rep,name=handlers,proto3" json:"handlers,omitempty"`
// contains filtered or unexported fields
}
Application is a protocol buffers representation of the configkit.Application interface.
func (*Application) Descriptor
deprecated
func (*Application) Descriptor() ([]byte, []int)
Deprecated: Use Application.ProtoReflect.Descriptor instead.
func (*Application) GetHandlers ¶
func (x *Application) GetHandlers() []*Handler
func (*Application) GetIdentity ¶
func (x *Application) GetIdentity() *Identity
func (*Application) GetMessages ¶
func (x *Application) GetMessages() []*NameRole
func (*Application) GetTypeName ¶
func (x *Application) GetTypeName() string
func (*Application) ProtoMessage ¶
func (*Application) ProtoMessage()
func (*Application) ProtoReflect ¶ added in v0.7.3
func (x *Application) ProtoReflect() protoreflect.Message
func (*Application) Reset ¶
func (x *Application) Reset()
func (*Application) String ¶
func (x *Application) String() string
type ConfigClient ¶
type ConfigClient interface {
// ListApplicationIdentities returns the identity of all applications.
ListApplicationIdentities(ctx context.Context, in *ListApplicationIdentitiesRequest, opts ...grpc.CallOption) (*ListApplicationIdentitiesResponse, error)
// ListApplications returns the full configuration of all applications.
ListApplications(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error)
// Watch opens a stream that sends no content, simply to detect when the
// server goes away.
Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Config_WatchClient, error)
}
ConfigClient is the client API for Config service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewConfigClient ¶
func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient
type ConfigServer ¶
type ConfigServer interface {
// ListApplicationIdentities returns the identity of all applications.
ListApplicationIdentities(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)
// ListApplications returns the full configuration of all applications.
ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)
// Watch opens a stream that sends no content, simply to detect when the
// server goes away.
Watch(*WatchRequest, Config_WatchServer) error
}
ConfigServer is the server API for Config service.
type Config_WatchClient ¶
type Config_WatchClient interface {
Recv() (*WatchResponse, error)
grpc.ClientStream
}
type Config_WatchServer ¶
type Config_WatchServer interface {
Send(*WatchResponse) error
grpc.ServerStream
}
type Handler ¶
type Handler struct {
// Identity is the handler's identity.
Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// TypeName is the fully-qualified name of the Go type used to implement the
// handler.
TypeName string `protobuf:"bytes,2,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
// Type is the handler's type.
Type HandlerType `protobuf:"varint,3,opt,name=type,proto3,enum=dogma.config.v1.HandlerType" json:"type,omitempty"`
// Produced is a list of the messages produced by this handler.
// Each value is the index of a MessageRolePair within the application.
Produced []uint32 `protobuf:"varint,4,rep,packed,name=produced,proto3" json:"produced,omitempty"`
// Consumed is a list of the messages consumed by this handler.
// Each value is the index of a MessageRolePair within the application.
Consumed []uint32 `protobuf:"varint,5,rep,packed,name=consumed,proto3" json:"consumed,omitempty"`
// contains filtered or unexported fields
}
Handler is a protocol buffers representation of the configkit.Handler interface.
func (*Handler) Descriptor
deprecated
func (*Handler) GetConsumed ¶
func (*Handler) GetIdentity ¶
func (*Handler) GetProduced ¶
func (*Handler) GetType ¶
func (x *Handler) GetType() HandlerType
func (*Handler) GetTypeName ¶
func (*Handler) ProtoMessage ¶
func (*Handler) ProtoMessage()
func (*Handler) ProtoReflect ¶ added in v0.7.3
func (x *Handler) ProtoReflect() protoreflect.Message
type HandlerType ¶
type HandlerType int32
HandlerType is a protocol buffers representation of the configkit.HandlerType enumeration.
const ( HandlerType_UNKNOWN_HANDLER_TYPE HandlerType = 0 HandlerType_AGGREGATE HandlerType = 1 HandlerType_PROCESS HandlerType = 2 HandlerType_INTEGRATION HandlerType = 3 HandlerType_PROJECTION HandlerType = 4 )
func (HandlerType) Descriptor ¶ added in v0.7.3
func (HandlerType) Descriptor() protoreflect.EnumDescriptor
func (HandlerType) Enum ¶ added in v0.7.3
func (x HandlerType) Enum() *HandlerType
func (HandlerType) EnumDescriptor
deprecated
func (HandlerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use HandlerType.Descriptor instead.
func (HandlerType) Number ¶ added in v0.7.3
func (x HandlerType) Number() protoreflect.EnumNumber
func (HandlerType) String ¶
func (x HandlerType) String() string
func (HandlerType) Type ¶ added in v0.7.3
func (HandlerType) Type() protoreflect.EnumType
type Identity ¶
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 is a protocol buffers representation of the configkit.Identity type.
func (*Identity) Descriptor
deprecated
func (*Identity) ProtoMessage ¶
func (*Identity) ProtoMessage()
func (*Identity) ProtoReflect ¶ added in v0.7.3
func (x *Identity) ProtoReflect() protoreflect.Message
type ListApplicationIdentitiesRequest ¶
type ListApplicationIdentitiesRequest struct {
// contains filtered or unexported fields
}
func (*ListApplicationIdentitiesRequest) Descriptor
deprecated
func (*ListApplicationIdentitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListApplicationIdentitiesRequest.ProtoReflect.Descriptor instead.
func (*ListApplicationIdentitiesRequest) ProtoMessage ¶
func (*ListApplicationIdentitiesRequest) ProtoMessage()
func (*ListApplicationIdentitiesRequest) ProtoReflect ¶ added in v0.7.3
func (x *ListApplicationIdentitiesRequest) ProtoReflect() protoreflect.Message
func (*ListApplicationIdentitiesRequest) Reset ¶
func (x *ListApplicationIdentitiesRequest) Reset()
func (*ListApplicationIdentitiesRequest) String ¶
func (x *ListApplicationIdentitiesRequest) String() string
type ListApplicationIdentitiesResponse ¶
type ListApplicationIdentitiesResponse struct {
Identities []*Identity `protobuf:"bytes,1,rep,name=identities,proto3" json:"identities,omitempty"`
// contains filtered or unexported fields
}
func (*ListApplicationIdentitiesResponse) Descriptor
deprecated
func (*ListApplicationIdentitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListApplicationIdentitiesResponse.ProtoReflect.Descriptor instead.
func (*ListApplicationIdentitiesResponse) GetIdentities ¶
func (x *ListApplicationIdentitiesResponse) GetIdentities() []*Identity
func (*ListApplicationIdentitiesResponse) ProtoMessage ¶
func (*ListApplicationIdentitiesResponse) ProtoMessage()
func (*ListApplicationIdentitiesResponse) ProtoReflect ¶ added in v0.7.3
func (x *ListApplicationIdentitiesResponse) ProtoReflect() protoreflect.Message
func (*ListApplicationIdentitiesResponse) Reset ¶
func (x *ListApplicationIdentitiesResponse) Reset()
func (*ListApplicationIdentitiesResponse) String ¶
func (x *ListApplicationIdentitiesResponse) String() string
type ListApplicationsRequest ¶
type ListApplicationsRequest struct {
// contains filtered or unexported fields
}
func (*ListApplicationsRequest) Descriptor
deprecated
func (*ListApplicationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListApplicationsRequest.ProtoReflect.Descriptor instead.
func (*ListApplicationsRequest) ProtoMessage ¶
func (*ListApplicationsRequest) ProtoMessage()
func (*ListApplicationsRequest) ProtoReflect ¶ added in v0.7.3
func (x *ListApplicationsRequest) ProtoReflect() protoreflect.Message
func (*ListApplicationsRequest) Reset ¶
func (x *ListApplicationsRequest) Reset()
func (*ListApplicationsRequest) String ¶
func (x *ListApplicationsRequest) String() string
type ListApplicationsResponse ¶
type ListApplicationsResponse struct {
Applications []*Application `protobuf:"bytes,1,rep,name=applications,proto3" json:"applications,omitempty"`
// contains filtered or unexported fields
}
func (*ListApplicationsResponse) Descriptor
deprecated
func (*ListApplicationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListApplicationsResponse.ProtoReflect.Descriptor instead.
func (*ListApplicationsResponse) GetApplications ¶
func (x *ListApplicationsResponse) GetApplications() []*Application
func (*ListApplicationsResponse) ProtoMessage ¶
func (*ListApplicationsResponse) ProtoMessage()
func (*ListApplicationsResponse) ProtoReflect ¶ added in v0.7.3
func (x *ListApplicationsResponse) ProtoReflect() protoreflect.Message
func (*ListApplicationsResponse) Reset ¶
func (x *ListApplicationsResponse) Reset()
func (*ListApplicationsResponse) String ¶
func (x *ListApplicationsResponse) String() string
type MessageRole ¶
type MessageRole int32
MessageRole is a protocol buffers representation of the configkit/message.Role enumeration.
const ( MessageRole_UNKNOWN_MESSAGE_ROLE MessageRole = 0 MessageRole_COMMAND MessageRole = 1 MessageRole_EVENT MessageRole = 2 MessageRole_TIMEOUT MessageRole = 3 )
func (MessageRole) Descriptor ¶ added in v0.7.3
func (MessageRole) Descriptor() protoreflect.EnumDescriptor
func (MessageRole) Enum ¶ added in v0.7.3
func (x MessageRole) Enum() *MessageRole
func (MessageRole) EnumDescriptor
deprecated
func (MessageRole) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageRole.Descriptor instead.
func (MessageRole) Number ¶ added in v0.7.3
func (x MessageRole) Number() protoreflect.EnumNumber
func (MessageRole) String ¶
func (x MessageRole) String() string
func (MessageRole) Type ¶ added in v0.7.3
func (MessageRole) Type() protoreflect.EnumType
type NameRole ¶
type NameRole struct {
// Name is the fully-qualified message name.
Name []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Role is the role this message plays within the application.
Role MessageRole `protobuf:"varint,2,opt,name=role,proto3,enum=dogma.config.v1.MessageRole" json:"role,omitempty"`
// contains filtered or unexported fields
}
NameRole is a 2-tuple containing a message name and its role.
func (*NameRole) Descriptor
deprecated
func (*NameRole) GetRole ¶
func (x *NameRole) GetRole() MessageRole
func (*NameRole) ProtoMessage ¶
func (*NameRole) ProtoMessage()
func (*NameRole) ProtoReflect ¶ added in v0.7.3
func (x *NameRole) ProtoReflect() protoreflect.Message
type UnimplementedConfigServer ¶
type UnimplementedConfigServer struct {
}
UnimplementedConfigServer can be embedded to have forward compatible implementations.
func (*UnimplementedConfigServer) ListApplicationIdentities ¶
func (*UnimplementedConfigServer) ListApplicationIdentities(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)
func (*UnimplementedConfigServer) ListApplications ¶
func (*UnimplementedConfigServer) ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)
func (*UnimplementedConfigServer) Watch ¶
func (*UnimplementedConfigServer) Watch(*WatchRequest, Config_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 ¶ added in v0.7.3
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 ¶ added in v0.7.3
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string