pb

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var File_api_internal_pb_service_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Handler.ProtoReflect.Descriptor instead.

func (*Handler) GetConsumed 

func (x *Handler) GetConsumed() []uint32

func (*Handler) GetIdentity 

func (x *Handler) GetIdentity() *Identity

func (*Handler) GetProduced 

func (x *Handler) GetProduced() []uint32

func (*Handler) GetType 

func (x *Handler) GetType() HandlerType

func (*Handler) GetTypeName 

func (x *Handler) GetTypeName() string

func (*Handler) ProtoMessage 

func (*Handler) ProtoMessage()

func (*Handler) ProtoReflect added in v0.7.3 

func (x *Handler) ProtoReflect() protoreflect.Message

func (*Handler) Reset 

func (x *Handler) Reset()

func (*Handler) String 

func (x *Handler) String() string

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetKey 

func (x *Identity) GetKey() string

func (*Identity) GetName 

func (x *Identity) GetName() string

func (*Identity) ProtoMessage 

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect added in v0.7.3 

func (x *Identity) ProtoReflect() protoreflect.Message

func (*Identity) Reset 

func (x *Identity) Reset()

func (*Identity) String 

func (x *Identity) String() string

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

Deprecated: Use NameRole.ProtoReflect.Descriptor instead.

func (*NameRole) GetName 

func (x *NameRole) GetName() []byte

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

func (*NameRole) Reset 

func (x *NameRole) Reset()

func (*NameRole) String 

func (x *NameRole) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.