pb

Apr 30, 2020

Changes in this version

+ var File_api_internal_pb_service_proto protoreflect.FileDescriptor

+ var File_api_internal_pb_types_proto protoreflect.FileDescriptor

type Application

+ func (x *Application) ProtoReflect() protoreflect.Message

type Handler

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

type HandlerType

+ func (HandlerType) Descriptor() protoreflect.EnumDescriptor

+ func (HandlerType) Type() protoreflect.EnumType

+ func (x HandlerType) Enum() *HandlerType

+ func (x HandlerType) Number() protoreflect.EnumNumber

type Identity

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

type ListApplicationIdentitiesRequest

+ func (x *ListApplicationIdentitiesRequest) ProtoReflect() protoreflect.Message

type ListApplicationIdentitiesResponse

+ func (x *ListApplicationIdentitiesResponse) ProtoReflect() protoreflect.Message

type ListApplicationsRequest

+ func (x *ListApplicationsRequest) ProtoReflect() protoreflect.Message

type ListApplicationsResponse

+ func (x *ListApplicationsResponse) ProtoReflect() protoreflect.Message

type MessageRole

+ func (MessageRole) Descriptor() protoreflect.EnumDescriptor

+ func (MessageRole) Type() protoreflect.EnumType

+ func (x MessageRole) Enum() *MessageRole

+ func (x MessageRole) Number() protoreflect.EnumNumber

type NameRole

+ func (x *NameRole) ProtoReflect() protoreflect.Message

type WatchRequest

+ func (x *WatchRequest) ProtoReflect() protoreflect.Message

type WatchResponse

+ func (x *WatchResponse) ProtoReflect() protoreflect.Message

Mar 8, 2020

Changes in this version

+ var HandlerType_name = map[int32]string

+ var HandlerType_value = map[string]int32

+ var MessageRole_name = map[int32]string

+ var MessageRole_value = map[string]int32

+ func RegisterConfigServer(s *grpc.Server, srv ConfigServer)

+ type Application struct

+ Handlers []*Handler

+ Identity *Identity

+ Messages []*NameRole

+ TypeName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Application) Descriptor() ([]byte, []int)

+ func (*Application) ProtoMessage()

+ func (m *Application) GetHandlers() []*Handler

+ func (m *Application) GetIdentity() *Identity

+ func (m *Application) GetMessages() []*NameRole

+ func (m *Application) GetTypeName() string

+ func (m *Application) Reset()

+ func (m *Application) String() string

+ func (m *Application) XXX_DiscardUnknown()

+ func (m *Application) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Application) XXX_Merge(src proto.Message)

+ func (m *Application) XXX_Size() int

+ func (m *Application) XXX_Unmarshal(b []byte) error

+ type ConfigClient interface

+ ListApplicationIdentities func(ctx context.Context, in *ListApplicationIdentitiesRequest, ...) (*ListApplicationIdentitiesResponse, error)

+ ListApplications func(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error)

+ Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Config_WatchClient, error)

+ func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient

+ type ConfigServer interface

+ ListApplicationIdentities func(context.Context, *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)

+ ListApplications func(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)

+ Watch func(*WatchRequest, Config_WatchServer) error

+ type Config_WatchClient interface

+ Recv func() (*WatchResponse, error)

+ type Config_WatchServer interface

+ Send func(*WatchResponse) error

+ type Handler struct

+ Consumed []uint32

+ Identity *Identity

+ Produced []uint32

+ Type HandlerType

+ TypeName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Handler) Descriptor() ([]byte, []int)

+ func (*Handler) ProtoMessage()

+ func (m *Handler) GetConsumed() []uint32

+ func (m *Handler) GetIdentity() *Identity

+ func (m *Handler) GetProduced() []uint32

+ func (m *Handler) GetType() HandlerType

+ func (m *Handler) GetTypeName() string

+ func (m *Handler) Reset()

+ func (m *Handler) String() string

+ func (m *Handler) XXX_DiscardUnknown()

+ func (m *Handler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Handler) XXX_Merge(src proto.Message)

+ func (m *Handler) XXX_Size() int

+ func (m *Handler) XXX_Unmarshal(b []byte) error

+ type HandlerType int32

+ const HandlerType_AGGREGATE

+ const HandlerType_INTEGRATION

+ const HandlerType_PROCESS

+ const HandlerType_PROJECTION

+ const HandlerType_UNKNOWN_HANDLER_TYPE

+ func (HandlerType) EnumDescriptor() ([]byte, []int)

+ func (x HandlerType) String() string

+ type Identity struct

+ Key string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Identity) Descriptor() ([]byte, []int)

+ func (*Identity) ProtoMessage()

+ func (m *Identity) GetKey() string

+ func (m *Identity) GetName() string

+ func (m *Identity) Reset()

+ func (m *Identity) String() string

+ func (m *Identity) XXX_DiscardUnknown()

+ func (m *Identity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Identity) XXX_Merge(src proto.Message)

+ func (m *Identity) XXX_Size() int

+ func (m *Identity) XXX_Unmarshal(b []byte) error

+ type ListApplicationIdentitiesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListApplicationIdentitiesRequest) Descriptor() ([]byte, []int)

+ func (*ListApplicationIdentitiesRequest) ProtoMessage()

+ func (m *ListApplicationIdentitiesRequest) Reset()

+ func (m *ListApplicationIdentitiesRequest) String() string

+ func (m *ListApplicationIdentitiesRequest) XXX_DiscardUnknown()

+ func (m *ListApplicationIdentitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListApplicationIdentitiesRequest) XXX_Merge(src proto.Message)

+ func (m *ListApplicationIdentitiesRequest) XXX_Size() int

+ func (m *ListApplicationIdentitiesRequest) XXX_Unmarshal(b []byte) error

+ type ListApplicationIdentitiesResponse struct

+ Identities []*Identity

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListApplicationIdentitiesResponse) Descriptor() ([]byte, []int)

+ func (*ListApplicationIdentitiesResponse) ProtoMessage()

+ func (m *ListApplicationIdentitiesResponse) GetIdentities() []*Identity

+ func (m *ListApplicationIdentitiesResponse) Reset()

+ func (m *ListApplicationIdentitiesResponse) String() string

+ func (m *ListApplicationIdentitiesResponse) XXX_DiscardUnknown()

+ func (m *ListApplicationIdentitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListApplicationIdentitiesResponse) XXX_Merge(src proto.Message)

+ func (m *ListApplicationIdentitiesResponse) XXX_Size() int

+ func (m *ListApplicationIdentitiesResponse) XXX_Unmarshal(b []byte) error

+ type ListApplicationsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListApplicationsRequest) Descriptor() ([]byte, []int)

+ func (*ListApplicationsRequest) ProtoMessage()

+ func (m *ListApplicationsRequest) Reset()

+ func (m *ListApplicationsRequest) String() string

+ func (m *ListApplicationsRequest) XXX_DiscardUnknown()

+ func (m *ListApplicationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListApplicationsRequest) XXX_Merge(src proto.Message)

+ func (m *ListApplicationsRequest) XXX_Size() int

+ func (m *ListApplicationsRequest) XXX_Unmarshal(b []byte) error

+ type ListApplicationsResponse struct

+ Applications []*Application

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListApplicationsResponse) Descriptor() ([]byte, []int)

+ func (*ListApplicationsResponse) ProtoMessage()

+ func (m *ListApplicationsResponse) GetApplications() []*Application

+ func (m *ListApplicationsResponse) Reset()

+ func (m *ListApplicationsResponse) String() string

+ func (m *ListApplicationsResponse) XXX_DiscardUnknown()

+ func (m *ListApplicationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListApplicationsResponse) XXX_Merge(src proto.Message)

+ func (m *ListApplicationsResponse) XXX_Size() int

+ func (m *ListApplicationsResponse) XXX_Unmarshal(b []byte) error

+ type MessageRole int32

+ const MessageRole_COMMAND

+ const MessageRole_EVENT

+ const MessageRole_TIMEOUT

+ const MessageRole_UNKNOWN_MESSAGE_ROLE

+ func (MessageRole) EnumDescriptor() ([]byte, []int)

+ func (x MessageRole) String() string

+ type NameRole struct

+ Name []byte

+ Role MessageRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NameRole) Descriptor() ([]byte, []int)

+ func (*NameRole) ProtoMessage()

+ func (m *NameRole) GetName() []byte

+ func (m *NameRole) GetRole() MessageRole

+ func (m *NameRole) Reset()

+ func (m *NameRole) String() string

+ func (m *NameRole) XXX_DiscardUnknown()

+ func (m *NameRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NameRole) XXX_Merge(src proto.Message)

+ func (m *NameRole) XXX_Size() int

+ func (m *NameRole) XXX_Unmarshal(b []byte) error

+ type UnimplementedConfigServer struct

+ func (*UnimplementedConfigServer) ListApplicationIdentities(ctx context.Context, req *ListApplicationIdentitiesRequest) (*ListApplicationIdentitiesResponse, error)

+ func (*UnimplementedConfigServer) ListApplications(ctx context.Context, req *ListApplicationsRequest) (*ListApplicationsResponse, error)

+ func (*UnimplementedConfigServer) Watch(req *WatchRequest, srv Config_WatchServer) error

+ type WatchRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WatchRequest) Descriptor() ([]byte, []int)

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) Reset()

+ func (m *WatchRequest) String() string

+ func (m *WatchRequest) XXX_DiscardUnknown()

+ func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchRequest) XXX_Merge(src proto.Message)

+ func (m *WatchRequest) XXX_Size() int

+ func (m *WatchRequest) XXX_Unmarshal(b []byte) error

+ type WatchResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WatchResponse) Descriptor() ([]byte, []int)

+ func (*WatchResponse) ProtoMessage()

+ func (m *WatchResponse) Reset()

+ func (m *WatchResponse) String() string

+ func (m *WatchResponse) XXX_DiscardUnknown()

+ func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchResponse) XXX_Merge(src proto.Message)

+ func (m *WatchResponse) XXX_Size() int

+ func (m *WatchResponse) XXX_Unmarshal(b []byte) error