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