Documentation ¶
Overview ¶
This code was autogenerated from xbus/xbus.proto, do not edit.
Index ¶
- Constants
- Variables
- func ActorInputSubject(id UUID, output string) string
- func ActorOutputSubject(id UUID) string
- func ClientProtoError(msg string, fmtArgs ...interface{}) *nrpc.Error
- func EmitterEnvelopeStateSubject(emitter UUID, envelopeID UUID) string
- func EmitterMsgboxSubject(id UUID) string
- func ItemsAsChunks(items []Item) [][]byte
- func JSONMarshal(encodings []ItemEncoding, pb proto.Message) ([]byte, error)
- func ServerProtoError(err error) *nrpc.Error
- func UUIDToStringOrWildcard(value UUID) string
- func WhoAmISubjects(apiKey string) (string, string)
- type Account
- func (*Account) Descriptor() ([]byte, []int)
- func (this *Account) Equal(that interface{}) bool
- func (m *Account) GetAPIKey() string
- func (m *Account) GetCSR() string
- func (m *Account) GetCSROrigin() Account_CSROrigin
- func (m *Account) GetCert() string
- func (m *Account) GetName() string
- func (m *Account) GetStatus() Account_Status
- func (m *Account) GetType() Account_Type
- func (this *Account) GoString() string
- func (m *Account) Marshal() (dAtA []byte, err error)
- func (m *Account) MarshalTo(dAtA []byte) (int, error)
- func (m *Account) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Account) ProtoMessage()
- func (m *Account) Reset()
- func (m *Account) Size() (n int)
- func (this *Account) String() string
- func (m *Account) Unmarshal(dAtA []byte) error
- func (this *Account) VerboseEqual(that interface{}) error
- func (m *Account) XXX_DiscardUnknown()
- func (m *Account) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Account) XXX_Merge(src proto.Message)
- func (m *Account) XXX_Size() int
- func (m *Account) XXX_Unmarshal(b []byte) error
- type Account_CSROrigin
- type Account_Status
- type Account_Type
- type AckResultRequest
- func (*AckResultRequest) Descriptor() ([]byte, []int)
- func (this *AckResultRequest) Equal(that interface{}) bool
- func (this *AckResultRequest) GoString() string
- func (m *AckResultRequest) Marshal() (dAtA []byte, err error)
- func (m *AckResultRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AckResultRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AckResultRequest) ProtoMessage()
- func (m *AckResultRequest) Reset()
- func (m *AckResultRequest) Size() (n int)
- func (this *AckResultRequest) String() string
- func (m *AckResultRequest) Unmarshal(dAtA []byte) error
- func (this *AckResultRequest) VerboseEqual(that interface{}) error
- func (m *AckResultRequest) XXX_DiscardUnknown()
- func (m *AckResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AckResultRequest) XXX_Merge(src proto.Message)
- func (m *AckResultRequest) XXX_Size() int
- func (m *AckResultRequest) XXX_Unmarshal(b []byte) error
- type Actor
- func (*Actor) Descriptor() ([]byte, []int)
- func (this *Actor) Equal(that interface{}) bool
- func (m *Actor) GetConfig() []ConfigEntry
- func (a *Actor) GetConfigEntry(key string) string
- func (m *Actor) GetKind() Actor_Kind
- func (m *Actor) GetLastSeen() time.Time
- func (m *Actor) GetName() string
- func (m *Actor) GetOnline() bool
- func (m *Actor) GetRoles() []string
- func (m *Actor) GetStatus() Actor_Status
- func (m *Actor) GetUnresponsive() bool
- func (this *Actor) GoString() string
- func (m *Actor) Marshal() (dAtA []byte, err error)
- func (m *Actor) MarshalTo(dAtA []byte) (int, error)
- func (m *Actor) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Actor) ProtoMessage()
- func (m *Actor) Reset()
- func (m *Actor) Size() (n int)
- func (this *Actor) String() string
- func (m *Actor) Unmarshal(dAtA []byte) error
- func (this *Actor) VerboseEqual(that interface{}) error
- func (m *Actor) XXX_DiscardUnknown()
- func (m *Actor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Actor) XXX_Merge(src proto.Message)
- func (m *Actor) XXX_Size() int
- func (m *Actor) XXX_Unmarshal(b []byte) error
- type ActorAgentClient
- type ActorAgentHandler
- type ActorAgentServer
- type ActorLogRequest
- func (*ActorLogRequest) Descriptor() ([]byte, []int)
- func (this *ActorLogRequest) Equal(that interface{}) bool
- func (m *ActorLogRequest) GetContext() *ProcessingContext
- func (m *ActorLogRequest) GetMessages() []LogMessage
- func (this *ActorLogRequest) GoString() string
- func (m *ActorLogRequest) Marshal() (dAtA []byte, err error)
- func (m *ActorLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorLogRequest) ProtoMessage()
- func (m *ActorLogRequest) Reset()
- func (m *ActorLogRequest) Size() (n int)
- func (this *ActorLogRequest) String() string
- func (m *ActorLogRequest) Unmarshal(dAtA []byte) error
- func (this *ActorLogRequest) VerboseEqual(that interface{}) error
- func (m *ActorLogRequest) XXX_DiscardUnknown()
- func (m *ActorLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorLogRequest) XXX_Merge(src proto.Message)
- func (m *ActorLogRequest) XXX_Size() int
- func (m *ActorLogRequest) XXX_Unmarshal(b []byte) error
- type ActorProcessRequest
- func (*ActorProcessRequest) Descriptor() ([]byte, []int)
- func (this *ActorProcessRequest) Equal(that interface{}) bool
- func (m *ActorProcessRequest) GetContext() *ProcessingContext
- func (m *ActorProcessRequest) GetInputs() []*ActorProcessRequest_Input
- func (this *ActorProcessRequest) GoString() string
- func (m *ActorProcessRequest) Marshal() (dAtA []byte, err error)
- func (m *ActorProcessRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorProcessRequest) ProtoMessage()
- func (m *ActorProcessRequest) Reset()
- func (m *ActorProcessRequest) Size() (n int)
- func (this *ActorProcessRequest) String() string
- func (m *ActorProcessRequest) Unmarshal(dAtA []byte) error
- func (this *ActorProcessRequest) VerboseEqual(that interface{}) error
- func (m *ActorProcessRequest) XXX_DiscardUnknown()
- func (m *ActorProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorProcessRequest) XXX_Merge(src proto.Message)
- func (m *ActorProcessRequest) XXX_Size() int
- func (m *ActorProcessRequest) XXX_Unmarshal(b []byte) error
- type ActorProcessRequest_Input
- func (*ActorProcessRequest_Input) Descriptor() ([]byte, []int)
- func (this *ActorProcessRequest_Input) Equal(that interface{}) bool
- func (m *ActorProcessRequest_Input) GetClose() bool
- func (m *ActorProcessRequest_Input) GetEnvelope() *Envelope
- func (m *ActorProcessRequest_Input) GetName() string
- func (m *ActorProcessRequest_Input) GetPosition() *EnvelopePosition
- func (this *ActorProcessRequest_Input) GoString() string
- func (m *ActorProcessRequest_Input) Marshal() (dAtA []byte, err error)
- func (m *ActorProcessRequest_Input) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorProcessRequest_Input) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorProcessRequest_Input) ProtoMessage()
- func (m *ActorProcessRequest_Input) Reset()
- func (m *ActorProcessRequest_Input) Size() (n int)
- func (this *ActorProcessRequest_Input) String() string
- func (m *ActorProcessRequest_Input) Unmarshal(dAtA []byte) error
- func (this *ActorProcessRequest_Input) VerboseEqual(that interface{}) error
- func (m *ActorProcessRequest_Input) XXX_DiscardUnknown()
- func (m *ActorProcessRequest_Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorProcessRequest_Input) XXX_Merge(src proto.Message)
- func (m *ActorProcessRequest_Input) XXX_Size() int
- func (m *ActorProcessRequest_Input) XXX_Unmarshal(b []byte) error
- type ActorProcessingState
- func (*ActorProcessingState) Descriptor() ([]byte, []int)
- func (this *ActorProcessingState) Equal(that interface{}) bool
- func (m *ActorProcessingState) GetActorLeaving() bool
- func (m *ActorProcessingState) GetContext() ProcessingContext
- func (m *ActorProcessingState) GetMessages() []LogMessage
- func (m *ActorProcessingState) GetStatus() ActorProcessingState_Status
- func (this *ActorProcessingState) GoString() string
- func (m *ActorProcessingState) Marshal() (dAtA []byte, err error)
- func (m *ActorProcessingState) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorProcessingState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorProcessingState) ProtoMessage()
- func (m *ActorProcessingState) Reset()
- func (m *ActorProcessingState) Size() (n int)
- func (this *ActorProcessingState) String() string
- func (m *ActorProcessingState) Unmarshal(dAtA []byte) error
- func (this *ActorProcessingState) VerboseEqual(that interface{}) error
- func (m *ActorProcessingState) XXX_DiscardUnknown()
- func (m *ActorProcessingState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorProcessingState) XXX_Merge(src proto.Message)
- func (m *ActorProcessingState) XXX_Size() int
- func (m *ActorProcessingState) XXX_Unmarshal(b []byte) error
- type ActorProcessingState_Status
- type ActorReadyMsg
- func (*ActorReadyMsg) Descriptor() ([]byte, []int)
- func (this *ActorReadyMsg) Equal(that interface{}) bool
- func (this *ActorReadyMsg) GoString() string
- func (m *ActorReadyMsg) Marshal() (dAtA []byte, err error)
- func (m *ActorReadyMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorReadyMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorReadyMsg) ProtoMessage()
- func (m *ActorReadyMsg) Reset()
- func (m *ActorReadyMsg) Size() (n int)
- func (this *ActorReadyMsg) String() string
- func (m *ActorReadyMsg) Unmarshal(dAtA []byte) error
- func (this *ActorReadyMsg) VerboseEqual(that interface{}) error
- func (m *ActorReadyMsg) XXX_DiscardUnknown()
- func (m *ActorReadyMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorReadyMsg) XXX_Merge(src proto.Message)
- func (m *ActorReadyMsg) XXX_Size() int
- func (m *ActorReadyMsg) XXX_Unmarshal(b []byte) error
- type Actor_Kind
- type Actor_Status
- type BrokerClient
- type BrokerHandler
- type BrokerServer
- type Checksum
- type Client
- func (c *Client) NewActorAgent(actorID string) *ActorAgentClient
- func (c *Client) NewBroker(actorID string) *BrokerClient
- func (c *Client) NewClientAPI(accountID string) *ClientAPIClient
- func (c *Client) SetActorAgentParams(actorID string)
- func (c *Client) SetBrokerParams(actorID string)
- func (c *Client) SetClientAPIParams(accountID string)
- func (c *Client) SetEncoding(encoding string)
- func (c *Client) SetTimeout(t time.Duration)
- type ClientAPIClient
- type ClientAPIHandler
- type ClientAPIServer
- type ClientGetActorsReply
- func (*ClientGetActorsReply) Descriptor() ([]byte, []int)
- func (this *ClientGetActorsReply) Equal(that interface{}) bool
- func (m *ClientGetActorsReply) GetActors() []Actor
- func (this *ClientGetActorsReply) GoString() string
- func (m *ClientGetActorsReply) Marshal() (dAtA []byte, err error)
- func (m *ClientGetActorsReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ClientGetActorsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClientGetActorsReply) ProtoMessage()
- func (m *ClientGetActorsReply) Reset()
- func (m *ClientGetActorsReply) Size() (n int)
- func (this *ClientGetActorsReply) String() string
- func (m *ClientGetActorsReply) Unmarshal(dAtA []byte) error
- func (this *ClientGetActorsReply) VerboseEqual(that interface{}) error
- func (m *ClientGetActorsReply) XXX_DiscardUnknown()
- func (m *ClientGetActorsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientGetActorsReply) XXX_Merge(src proto.Message)
- func (m *ClientGetActorsReply) XXX_Size() int
- func (m *ClientGetActorsReply) XXX_Unmarshal(b []byte) error
- type ClientGetActorsRequest
- func (*ClientGetActorsRequest) Descriptor() ([]byte, []int)
- func (this *ClientGetActorsRequest) Equal(that interface{}) bool
- func (this *ClientGetActorsRequest) GoString() string
- func (m *ClientGetActorsRequest) Marshal() (dAtA []byte, err error)
- func (m *ClientGetActorsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ClientGetActorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClientGetActorsRequest) ProtoMessage()
- func (m *ClientGetActorsRequest) Reset()
- func (m *ClientGetActorsRequest) Size() (n int)
- func (this *ClientGetActorsRequest) String() string
- func (m *ClientGetActorsRequest) Unmarshal(dAtA []byte) error
- func (this *ClientGetActorsRequest) VerboseEqual(that interface{}) error
- func (m *ClientGetActorsRequest) XXX_DiscardUnknown()
- func (m *ClientGetActorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientGetActorsRequest) XXX_Merge(src proto.Message)
- func (m *ClientGetActorsRequest) XXX_Size() int
- func (m *ClientGetActorsRequest) XXX_Unmarshal(b []byte) error
- type ConfigEntry
- func (*ConfigEntry) Descriptor() ([]byte, []int)
- func (this *ConfigEntry) Equal(that interface{}) bool
- func (m *ConfigEntry) GetKey() string
- func (m *ConfigEntry) GetValue() string
- func (this *ConfigEntry) GoString() string
- func (m *ConfigEntry) Marshal() (dAtA []byte, err error)
- func (m *ConfigEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigEntry) ProtoMessage()
- func (m *ConfigEntry) Reset()
- func (m *ConfigEntry) Size() (n int)
- func (this *ConfigEntry) String() string
- func (m *ConfigEntry) Unmarshal(dAtA []byte) error
- func (this *ConfigEntry) VerboseEqual(that interface{}) error
- func (m *ConfigEntry) XXX_DiscardUnknown()
- func (m *ConfigEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigEntry) XXX_Merge(src proto.Message)
- func (m *ConfigEntry) XXX_Size() int
- func (m *ConfigEntry) XXX_Unmarshal(b []byte) error
- type CoreEvent
- func (*CoreEvent) Descriptor() ([]byte, []int)
- func (this *CoreEvent) Equal(that interface{}) bool
- func (m *CoreEvent) GetActor() *Actor
- func (m *CoreEvent) GetName() string
- func (m *CoreEvent) GetProcess() *Process
- func (m *CoreEvent) GetProcessOldStatus() Process_Status
- func (this *CoreEvent) GoString() string
- func (m *CoreEvent) Marshal() (dAtA []byte, err error)
- func (m *CoreEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *CoreEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CoreEvent) ProtoMessage()
- func (m *CoreEvent) Reset()
- func (m *CoreEvent) Size() (n int)
- func (this *CoreEvent) String() string
- func (m *CoreEvent) Unmarshal(dAtA []byte) error
- func (this *CoreEvent) VerboseEqual(that interface{}) error
- func (m *CoreEvent) XXX_DiscardUnknown()
- func (m *CoreEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoreEvent) XXX_Merge(src proto.Message)
- func (m *CoreEvent) XXX_Size() int
- func (m *CoreEvent) XXX_Unmarshal(b []byte) error
- type CoreEventsActorSubscription
- type CoreEventsClient
- func (c *CoreEventsClient) ActorSubject() string
- func (c *CoreEventsClient) ActorSubscribe(handler func(CoreEvent)) (sub *nats.Subscription, err error)
- func (c *CoreEventsClient) ActorSubscribeChan() (<-chan CoreEvent, *nats.Subscription, error)
- func (c *CoreEventsClient) ActorSubscribeSync() (sub *CoreEventsActorSubscription, err error)
- func (c *CoreEventsClient) EnvelopeSubject() string
- func (c *CoreEventsClient) EnvelopeSubscribe(handler func(EnvelopeEvent)) (sub *nats.Subscription, err error)
- func (c *CoreEventsClient) EnvelopeSubscribeChan() (<-chan EnvelopeEvent, *nats.Subscription, error)
- func (c *CoreEventsClient) EnvelopeSubscribeSync() (sub *CoreEventsEnvelopeSubscription, err error)
- func (c *CoreEventsClient) ProcessNodeReadySubject() string
- func (c *CoreEventsClient) ProcessNodeReadySubscribe(handler func(ProcessNodeReadyEvent)) (sub *nats.Subscription, err error)
- func (c *CoreEventsClient) ProcessNodeReadySubscribeChan() (<-chan ProcessNodeReadyEvent, *nats.Subscription, error)
- func (c *CoreEventsClient) ProcessNodeReadySubscribeSync() (sub *CoreEventsProcessNodeReadySubscription, err error)
- func (c *CoreEventsClient) ProcessSubject() string
- func (c *CoreEventsClient) ProcessSubscribe(handler func(CoreEvent)) (sub *nats.Subscription, err error)
- func (c *CoreEventsClient) ProcessSubscribeChan() (<-chan CoreEvent, *nats.Subscription, error)
- func (c *CoreEventsClient) ProcessSubscribeSync() (sub *CoreEventsProcessSubscription, err error)
- type CoreEventsEnvelopeSubscription
- type CoreEventsHandler
- func (h *CoreEventsHandler) ActorPublish(msg CoreEvent) error
- func (h *CoreEventsHandler) EnvelopePublish(msg EnvelopeEvent) error
- func (h *CoreEventsHandler) ProcessNodeReadyPublish(msg ProcessNodeReadyEvent) error
- func (h *CoreEventsHandler) ProcessPublish(msg CoreEvent) error
- func (h *CoreEventsHandler) SetEncodings(encodings []string)
- func (h *CoreEventsHandler) Subject() string
- type CoreEventsProcessNodeReadySubscription
- type CoreEventsProcessSubscription
- type CoreEventsServer
- type DirectorClient
- type DirectorHandler
- type DirectorServer
- type EmitterEnvelopeState
- func (*EmitterEnvelopeState) Descriptor() ([]byte, []int)
- func (this *EmitterEnvelopeState) Equal(that interface{}) bool
- func (m *EmitterEnvelopeState) GetErrors() []LogMessage
- func (m *EmitterEnvelopeState) GetProcessCreatedAt() *time.Time
- func (m *EmitterEnvelopeState) GetResponse() *EnvelopeFragmentAndPosition
- func (m *EmitterEnvelopeState) GetStatus() Process_Status
- func (m *EmitterEnvelopeState) GetTriggerEnvelope() *EnvelopeFragmentAndPosition
- func (this *EmitterEnvelopeState) GoString() string
- func (m *EmitterEnvelopeState) Marshal() (dAtA []byte, err error)
- func (m *EmitterEnvelopeState) MarshalTo(dAtA []byte) (int, error)
- func (m *EmitterEnvelopeState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmitterEnvelopeState) ProtoMessage()
- func (m *EmitterEnvelopeState) Reset()
- func (m *EmitterEnvelopeState) Size() (n int)
- func (this *EmitterEnvelopeState) String() string
- func (m *EmitterEnvelopeState) Unmarshal(dAtA []byte) error
- func (this *EmitterEnvelopeState) VerboseEqual(that interface{}) error
- func (m *EmitterEnvelopeState) XXX_DiscardUnknown()
- func (m *EmitterEnvelopeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmitterEnvelopeState) XXX_Merge(src proto.Message)
- func (m *EmitterEnvelopeState) XXX_Size() int
- func (m *EmitterEnvelopeState) XXX_Unmarshal(b []byte) error
- type EmitterEnvelopeStateList
- func (*EmitterEnvelopeStateList) Descriptor() ([]byte, []int)
- func (this *EmitterEnvelopeStateList) Equal(that interface{}) bool
- func (m *EmitterEnvelopeStateList) GetList() []*EmitterEnvelopeState
- func (this *EmitterEnvelopeStateList) GoString() string
- func (m *EmitterEnvelopeStateList) Marshal() (dAtA []byte, err error)
- func (m *EmitterEnvelopeStateList) MarshalTo(dAtA []byte) (int, error)
- func (m *EmitterEnvelopeStateList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmitterEnvelopeStateList) ProtoMessage()
- func (m *EmitterEnvelopeStateList) Reset()
- func (m *EmitterEnvelopeStateList) Size() (n int)
- func (this *EmitterEnvelopeStateList) String() string
- func (m *EmitterEnvelopeStateList) Unmarshal(dAtA []byte) error
- func (this *EmitterEnvelopeStateList) VerboseEqual(that interface{}) error
- func (m *EmitterEnvelopeStateList) XXX_DiscardUnknown()
- func (m *EmitterEnvelopeStateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmitterEnvelopeStateList) XXX_Merge(src proto.Message)
- func (m *EmitterEnvelopeStateList) XXX_Size() int
- func (m *EmitterEnvelopeStateList) XXX_Unmarshal(b []byte) error
- type Envelope
- func (*Envelope) Descriptor() ([]byte, []int)
- func (this *Envelope) Equal(that interface{}) bool
- func (m *Envelope) GetEvents() []Event
- func (m *Envelope) GetLast() bool
- func (this *Envelope) GoString() string
- func (m *Envelope) Marshal() (dAtA []byte, err error)
- func (m *Envelope) MarshalTo(dAtA []byte) (int, error)
- func (m *Envelope) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Envelope) ProtoMessage()
- func (m *Envelope) Reset()
- func (m *Envelope) Size() (n int)
- func (this *Envelope) String() string
- func (m *Envelope) Unmarshal(dAtA []byte) error
- func (this *Envelope) VerboseEqual(that interface{}) error
- func (m *Envelope) XXX_DiscardUnknown()
- func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Envelope) XXX_Merge(src proto.Message)
- func (m *Envelope) XXX_Size() int
- func (m *Envelope) XXX_Unmarshal(b []byte) error
- type EnvelopeAck
- func (*EnvelopeAck) Descriptor() ([]byte, []int)
- func (this *EnvelopeAck) Equal(that interface{}) bool
- func (m *EnvelopeAck) GetReason() string
- func (m *EnvelopeAck) GetStatus() EnvelopeAck_ReceptionStatus
- func (this *EnvelopeAck) GoString() string
- func (m *EnvelopeAck) Marshal() (dAtA []byte, err error)
- func (m *EnvelopeAck) MarshalTo(dAtA []byte) (int, error)
- func (m *EnvelopeAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EnvelopeAck) ProtoMessage()
- func (m *EnvelopeAck) Reset()
- func (m *EnvelopeAck) Size() (n int)
- func (this *EnvelopeAck) String() string
- func (m *EnvelopeAck) Unmarshal(dAtA []byte) error
- func (this *EnvelopeAck) VerboseEqual(that interface{}) error
- func (m *EnvelopeAck) XXX_DiscardUnknown()
- func (m *EnvelopeAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvelopeAck) XXX_Merge(src proto.Message)
- func (m *EnvelopeAck) XXX_Size() int
- func (m *EnvelopeAck) XXX_Unmarshal(b []byte) error
- type EnvelopeAck_ReceptionStatus
- type EnvelopeEvent
- func (*EnvelopeEvent) Descriptor() ([]byte, []int)
- func (this *EnvelopeEvent) Equal(that interface{}) bool
- func (m *EnvelopeEvent) GetNewData() bool
- func (m *EnvelopeEvent) GetStatus() EnvelopeEvent_Status
- func (this *EnvelopeEvent) GoString() string
- func (m *EnvelopeEvent) Marshal() (dAtA []byte, err error)
- func (m *EnvelopeEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *EnvelopeEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EnvelopeEvent) ProtoMessage()
- func (m *EnvelopeEvent) Reset()
- func (m *EnvelopeEvent) Size() (n int)
- func (this *EnvelopeEvent) String() string
- func (m *EnvelopeEvent) Unmarshal(dAtA []byte) error
- func (this *EnvelopeEvent) VerboseEqual(that interface{}) error
- func (m *EnvelopeEvent) XXX_DiscardUnknown()
- func (m *EnvelopeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvelopeEvent) XXX_Merge(src proto.Message)
- func (m *EnvelopeEvent) XXX_Size() int
- func (m *EnvelopeEvent) XXX_Unmarshal(b []byte) error
- type EnvelopeEvent_Status
- type EnvelopeFragmentAndPosition
- func (*EnvelopeFragmentAndPosition) Descriptor() ([]byte, []int)
- func (this *EnvelopeFragmentAndPosition) Equal(that interface{}) bool
- func (m *EnvelopeFragmentAndPosition) GetFragment() *Envelope
- func (m *EnvelopeFragmentAndPosition) GetPosition() *EnvelopePosition
- func (this *EnvelopeFragmentAndPosition) GoString() string
- func (m *EnvelopeFragmentAndPosition) Marshal() (dAtA []byte, err error)
- func (m *EnvelopeFragmentAndPosition) MarshalTo(dAtA []byte) (int, error)
- func (m *EnvelopeFragmentAndPosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EnvelopeFragmentAndPosition) ProtoMessage()
- func (m *EnvelopeFragmentAndPosition) Reset()
- func (m *EnvelopeFragmentAndPosition) Size() (n int)
- func (this *EnvelopeFragmentAndPosition) String() string
- func (m *EnvelopeFragmentAndPosition) Unmarshal(dAtA []byte) error
- func (this *EnvelopeFragmentAndPosition) VerboseEqual(that interface{}) error
- func (m *EnvelopeFragmentAndPosition) XXX_DiscardUnknown()
- func (m *EnvelopeFragmentAndPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvelopeFragmentAndPosition) XXX_Merge(src proto.Message)
- func (m *EnvelopeFragmentAndPosition) XXX_Size() int
- func (m *EnvelopeFragmentAndPosition) XXX_Unmarshal(b []byte) error
- type EnvelopePosition
- func (*EnvelopePosition) Descriptor() ([]byte, []int)
- func (this *EnvelopePosition) Equal(that interface{}) bool
- func (m *EnvelopePosition) GetComplete() bool
- func (m *EnvelopePosition) GetEventPositions() []*EventPosition
- func (m *EnvelopePosition) GetStart() bool
- func (this *EnvelopePosition) GoString() string
- func (m *EnvelopePosition) Marshal() (dAtA []byte, err error)
- func (m *EnvelopePosition) MarshalTo(dAtA []byte) (int, error)
- func (m *EnvelopePosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EnvelopePosition) ProtoMessage()
- func (m *EnvelopePosition) Reset()
- func (m *EnvelopePosition) Size() (n int)
- func (this *EnvelopePosition) String() string
- func (m *EnvelopePosition) Unmarshal(dAtA []byte) error
- func (this *EnvelopePosition) VerboseEqual(that interface{}) error
- func (m *EnvelopePosition) XXX_DiscardUnknown()
- func (m *EnvelopePosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvelopePosition) XXX_Merge(src proto.Message)
- func (m *EnvelopePosition) XXX_Size() int
- func (m *EnvelopePosition) XXX_Unmarshal(b []byte) error
- type EnvelopeStorageClient
- type EnvelopeStorageHandler
- type EnvelopeStorageServer
- type EnvelopeTarget
- func (*EnvelopeTarget) Descriptor() ([]byte, []int)
- func (this *EnvelopeTarget) Equal(that interface{}) bool
- func (m *EnvelopeTarget) GetInput() string
- func (m *EnvelopeTarget) GetNodeID() string
- func (this *EnvelopeTarget) GoString() string
- func (m *EnvelopeTarget) Marshal() (dAtA []byte, err error)
- func (m *EnvelopeTarget) MarshalTo(dAtA []byte) (int, error)
- func (m *EnvelopeTarget) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EnvelopeTarget) ProtoMessage()
- func (m *EnvelopeTarget) Reset()
- func (m *EnvelopeTarget) Size() (n int)
- func (this *EnvelopeTarget) String() string
- func (m *EnvelopeTarget) Unmarshal(dAtA []byte) error
- func (this *EnvelopeTarget) VerboseEqual(that interface{}) error
- func (m *EnvelopeTarget) XXX_DiscardUnknown()
- func (m *EnvelopeTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvelopeTarget) XXX_Merge(src proto.Message)
- func (m *EnvelopeTarget) XXX_Size() int
- func (m *EnvelopeTarget) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (this *Event) Equal(that interface{}) bool
- func (m *Event) GetChecksum() Checksum
- func (m *Event) GetIndex() uint64
- func (m *Event) GetItemCount() uint64
- func (m *Event) GetItems() []Item
- func (m *Event) GetType() string
- func (this *Event) GoString() string
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (event Event) MarshalJSONPB(m *jsonpb.Marshaler) ([]byte, error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (this *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (event *Event) UnmarshalJSON(data []byte) error
- func (event *Event) UnmarshalJSONPB(u *jsonpb.Unmarshaler, data []byte) error
- func (this *Event) VerboseEqual(that interface{}) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventPosition
- func (*EventPosition) Descriptor() ([]byte, []int)
- func (this *EventPosition) Equal(that interface{}) bool
- func (m *EventPosition) GetIndex() uint64
- func (m *EventPosition) GetItemCount() uint64
- func (this *EventPosition) GoString() string
- func (m *EventPosition) Marshal() (dAtA []byte, err error)
- func (m *EventPosition) MarshalTo(dAtA []byte) (int, error)
- func (m *EventPosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventPosition) ProtoMessage()
- func (m *EventPosition) Reset()
- func (m *EventPosition) Size() (n int)
- func (this *EventPosition) String() string
- func (m *EventPosition) Unmarshal(dAtA []byte) error
- func (this *EventPosition) VerboseEqual(that interface{}) error
- func (m *EventPosition) XXX_DiscardUnknown()
- func (m *EventPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventPosition) XXX_Merge(src proto.Message)
- func (m *EventPosition) XXX_Size() int
- func (m *EventPosition) XXX_Unmarshal(b []byte) error
- type GetEnvelopeStateRequest
- func (*GetEnvelopeStateRequest) Descriptor() ([]byte, []int)
- func (this *GetEnvelopeStateRequest) Equal(that interface{}) bool
- func (this *GetEnvelopeStateRequest) GoString() string
- func (m *GetEnvelopeStateRequest) Marshal() (dAtA []byte, err error)
- func (m *GetEnvelopeStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetEnvelopeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetEnvelopeStateRequest) ProtoMessage()
- func (m *GetEnvelopeStateRequest) Reset()
- func (m *GetEnvelopeStateRequest) Size() (n int)
- func (this *GetEnvelopeStateRequest) String() string
- func (m *GetEnvelopeStateRequest) Unmarshal(dAtA []byte) error
- func (this *GetEnvelopeStateRequest) VerboseEqual(that interface{}) error
- func (m *GetEnvelopeStateRequest) XXX_DiscardUnknown()
- func (m *GetEnvelopeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetEnvelopeStateRequest) XXX_Merge(src proto.Message)
- func (m *GetEnvelopeStateRequest) XXX_Size() int
- func (m *GetEnvelopeStateRequest) XXX_Unmarshal(b []byte) error
- type GetSessionTokenRequest
- func (*GetSessionTokenRequest) Descriptor() ([]byte, []int)
- func (this *GetSessionTokenRequest) Equal(that interface{}) bool
- func (m *GetSessionTokenRequest) GetExpiresIn() uint32
- func (m *GetSessionTokenRequest) GetInvalidateToken() string
- func (this *GetSessionTokenRequest) GoString() string
- func (m *GetSessionTokenRequest) Marshal() (dAtA []byte, err error)
- func (m *GetSessionTokenRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetSessionTokenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetSessionTokenRequest) ProtoMessage()
- func (m *GetSessionTokenRequest) Reset()
- func (m *GetSessionTokenRequest) Size() (n int)
- func (this *GetSessionTokenRequest) String() string
- func (m *GetSessionTokenRequest) Unmarshal(dAtA []byte) error
- func (this *GetSessionTokenRequest) VerboseEqual(that interface{}) error
- func (m *GetSessionTokenRequest) XXX_DiscardUnknown()
- func (m *GetSessionTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSessionTokenRequest) XXX_Merge(src proto.Message)
- func (m *GetSessionTokenRequest) XXX_Size() int
- func (m *GetSessionTokenRequest) XXX_Unmarshal(b []byte) error
- type Item
- type ItemEncoding
- type JSONRawEvent
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)
- func (this *LogEntry) Equal(that interface{}) bool
- func (m *LogEntry) GetMessage() LogMessage
- func (m *LogEntry) GetNodeID() string
- func (this *LogEntry) GoString() string
- func (m *LogEntry) Marshal() (dAtA []byte, err error)
- func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) Size() (n int)
- func (this *LogEntry) String() string
- func (m *LogEntry) Unmarshal(dAtA []byte) error
- func (this *LogEntry) VerboseEqual(that interface{}) error
- func (m *LogEntry) XXX_DiscardUnknown()
- func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry) XXX_Merge(src proto.Message)
- func (m *LogEntry) XXX_Size() int
- func (m *LogEntry) XXX_Unmarshal(b []byte) error
- type LogLevel
- type LogMessage
- func (*LogMessage) Descriptor() ([]byte, []int)
- func (this *LogMessage) Equal(that interface{}) bool
- func (m *LogMessage) GetLevel() LogLevel
- func (m *LogMessage) GetText() string
- func (m *LogMessage) GetTime() time.Time
- func (this *LogMessage) GoString() string
- func (m *LogMessage) Marshal() (dAtA []byte, err error)
- func (m *LogMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *LogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogMessage) ProtoMessage()
- func (m *LogMessage) Reset()
- func (m *LogMessage) Size() (n int)
- func (this *LogMessage) String() string
- func (m *LogMessage) Unmarshal(dAtA []byte) error
- func (this *LogMessage) VerboseEqual(that interface{}) error
- func (m *LogMessage) XXX_DiscardUnknown()
- func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogMessage) XXX_Merge(src proto.Message)
- func (m *LogMessage) XXX_Size() int
- func (m *LogMessage) XXX_Unmarshal(b []byte) error
- type OutputRequest
- func (*OutputRequest) Descriptor() ([]byte, []int)
- func (this *OutputRequest) Equal(that interface{}) bool
- func (m *OutputRequest) GetClose() bool
- func (m *OutputRequest) GetContext() *ProcessingContext
- func (m *OutputRequest) GetEnvelope() *Envelope
- func (m *OutputRequest) GetOutput() string
- func (this *OutputRequest) GoString() string
- func (m *OutputRequest) Marshal() (dAtA []byte, err error)
- func (m *OutputRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OutputRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OutputRequest) ProtoMessage()
- func (m *OutputRequest) Reset()
- func (m *OutputRequest) Size() (n int)
- func (this *OutputRequest) String() string
- func (m *OutputRequest) Unmarshal(dAtA []byte) error
- func (this *OutputRequest) VerboseEqual(that interface{}) error
- func (m *OutputRequest) XXX_DiscardUnknown()
- func (m *OutputRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutputRequest) XXX_Merge(src proto.Message)
- func (m *OutputRequest) XXX_Size() int
- func (m *OutputRequest) XXX_Unmarshal(b []byte) error
- type PMProcess
- func (*PMProcess) Descriptor() ([]byte, []int)
- func (this *PMProcess) Equal(that interface{}) bool
- func (m *PMProcess) GetComment() string
- func (m *PMProcess) GetLevel() LogLevel
- func (m *PMProcess) GetLogs() []LogEntry
- func (m *PMProcess) GetProcess() Process
- func (m *PMProcess) GetStatus() PMProcess_Status
- func (this *PMProcess) GoString() string
- func (m *PMProcess) Marshal() (dAtA []byte, err error)
- func (m *PMProcess) MarshalTo(dAtA []byte) (int, error)
- func (m *PMProcess) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PMProcess) ProtoMessage()
- func (m *PMProcess) Reset()
- func (m *PMProcess) Size() (n int)
- func (this *PMProcess) String() string
- func (m *PMProcess) Unmarshal(dAtA []byte) error
- func (this *PMProcess) VerboseEqual(that interface{}) error
- func (m *PMProcess) XXX_DiscardUnknown()
- func (m *PMProcess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PMProcess) XXX_Merge(src proto.Message)
- func (m *PMProcess) XXX_Size() int
- func (m *PMProcess) XXX_Unmarshal(b []byte) error
- type PMProcess_Status
- type PipelineInfo
- func (*PipelineInfo) Descriptor() ([]byte, []int)
- func (this *PipelineInfo) Equal(that interface{}) bool
- func (m *PipelineInfo) GetName() string
- func (m *PipelineInfo) GetStatus() PipelineInfo_Status
- func (m *PipelineInfo) GetVersion() string
- func (this *PipelineInfo) GoString() string
- func (m *PipelineInfo) Marshal() (dAtA []byte, err error)
- func (m *PipelineInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineInfo) ProtoMessage()
- func (m *PipelineInfo) Reset()
- func (m *PipelineInfo) Size() (n int)
- func (this *PipelineInfo) String() string
- func (m *PipelineInfo) Unmarshal(dAtA []byte) error
- func (this *PipelineInfo) VerboseEqual(that interface{}) error
- func (m *PipelineInfo) XXX_DiscardUnknown()
- func (m *PipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineInfo) XXX_Merge(src proto.Message)
- func (m *PipelineInfo) XXX_Size() int
- func (m *PipelineInfo) XXX_Unmarshal(b []byte) error
- type PipelineInfo_Status
- type Process
- func (*Process) Descriptor() ([]byte, []int)
- func (this *Process) Equal(that interface{}) bool
- func (m *Process) GetCreatedAt() *time.Time
- func (m *Process) GetState() string
- func (m *Process) GetStatus() Process_Status
- func (this *Process) GoString() string
- func (m *Process) Marshal() (dAtA []byte, err error)
- func (m *Process) MarshalTo(dAtA []byte) (int, error)
- func (m *Process) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Process) ProtoMessage()
- func (m *Process) Reset()
- func (m *Process) Size() (n int)
- func (this *Process) String() string
- func (m *Process) Unmarshal(dAtA []byte) error
- func (this *Process) VerboseEqual(that interface{}) error
- func (m *Process) XXX_DiscardUnknown()
- func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Process) XXX_Merge(src proto.Message)
- func (m *Process) XXX_Size() int
- func (m *Process) XXX_Unmarshal(b []byte) error
- type ProcessFilter
- func (*ProcessFilter) Descriptor() ([]byte, []int)
- func (this *ProcessFilter) Equal(that interface{}) bool
- func (m *ProcessFilter) GetCreatedAt() *TimeRange
- func (m *ProcessFilter) GetResultAcked() []bool
- func (m *ProcessFilter) GetStatus() []Process_Status
- func (m *ProcessFilter) GetStatusChanged() *TimeRange
- func (m *ProcessFilter) GetStatusChangedFrom() *time.Time
- func (m *ProcessFilter) GetStatusChangedTo() *time.Time
- func (this *ProcessFilter) GoString() string
- func (m *ProcessFilter) Marshal() (dAtA []byte, err error)
- func (m *ProcessFilter) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessFilter) ProtoMessage()
- func (m *ProcessFilter) Reset()
- func (m *ProcessFilter) Size() (n int)
- func (this *ProcessFilter) String() string
- func (m *ProcessFilter) Unmarshal(dAtA []byte) error
- func (this *ProcessFilter) VerboseEqual(that interface{}) error
- func (m *ProcessFilter) XXX_DiscardUnknown()
- func (m *ProcessFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessFilter) XXX_Merge(src proto.Message)
- func (m *ProcessFilter) XXX_Size() int
- func (m *ProcessFilter) XXX_Unmarshal(b []byte) error
- type ProcessNodeReadyEvent
- func (*ProcessNodeReadyEvent) Descriptor() ([]byte, []int)
- func (this *ProcessNodeReadyEvent) Equal(that interface{}) bool
- func (m *ProcessNodeReadyEvent) GetNodeID() string
- func (this *ProcessNodeReadyEvent) GoString() string
- func (m *ProcessNodeReadyEvent) Marshal() (dAtA []byte, err error)
- func (m *ProcessNodeReadyEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessNodeReadyEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessNodeReadyEvent) ProtoMessage()
- func (m *ProcessNodeReadyEvent) Reset()
- func (m *ProcessNodeReadyEvent) Size() (n int)
- func (this *ProcessNodeReadyEvent) String() string
- func (m *ProcessNodeReadyEvent) Unmarshal(dAtA []byte) error
- func (this *ProcessNodeReadyEvent) VerboseEqual(that interface{}) error
- func (m *ProcessNodeReadyEvent) XXX_DiscardUnknown()
- func (m *ProcessNodeReadyEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessNodeReadyEvent) XXX_Merge(src proto.Message)
- func (m *ProcessNodeReadyEvent) XXX_Size() int
- func (m *ProcessNodeReadyEvent) XXX_Unmarshal(b []byte) error
- type ProcessStateClient
- func (c *ProcessStateClient) AckResult(emitterID string, req AckResultRequest) (err error)
- func (c *ProcessStateClient) EnvelopeStatesSubject(mtemitterID string, mtenvelopeID string) string
- func (c *ProcessStateClient) EnvelopeStatesSubscribe(mtemitterID string, mtenvelopeID string, handler func(EmitterEnvelopeState)) (sub *nats.Subscription, err error)
- func (c *ProcessStateClient) EnvelopeStatesSubscribeChan(mtemitterID string, mtenvelopeID string) (<-chan EmitterEnvelopeState, *nats.Subscription, error)
- func (c *ProcessStateClient) EnvelopeStatesSubscribeSync(mtemitterID string, mtenvelopeID string) (sub *ProcessStateEnvelopeStatesSubscription, err error)
- func (c *ProcessStateClient) GetEnvelopeState(emitterID string, req GetEnvelopeStateRequest) (resp EmitterEnvelopeState, err error)
- func (c *ProcessStateClient) List(ctx context.Context, emitterID string, req ProcessFilter, ...) error
- type ProcessStateEnvelopeStatesSubscription
- type ProcessStateHandler
- type ProcessStateServer
- type Process_Status
- type ProcessingContext
- func (*ProcessingContext) Descriptor() ([]byte, []int)
- func (this *ProcessingContext) Equal(that interface{}) bool
- func (m *ProcessingContext) GetNodeID() string
- func (this *ProcessingContext) GoString() string
- func (m *ProcessingContext) Marshal() (dAtA []byte, err error)
- func (m *ProcessingContext) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessingContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessingContext) ProtoMessage()
- func (m *ProcessingContext) Reset()
- func (m *ProcessingContext) Size() (n int)
- func (this *ProcessingContext) String() string
- func (m *ProcessingContext) Unmarshal(dAtA []byte) error
- func (this *ProcessingContext) VerboseEqual(that interface{}) error
- func (m *ProcessingContext) XXX_DiscardUnknown()
- func (m *ProcessingContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessingContext) XXX_Merge(src proto.Message)
- func (m *ProcessingContext) XXX_Size() int
- func (m *ProcessingContext) XXX_Unmarshal(b []byte) error
- type Registration
- func (*Registration) Descriptor() ([]byte, []int)
- func (this *Registration) Equal(that interface{}) bool
- func (m *Registration) GetActorList() []Actor
- func (m *Registration) GetRegistrationStatus() Registration_Status
- func (m *Registration) GetServerCA() string
- func (m *Registration) GetSignedCertificate() string
- func (this *Registration) GoString() string
- func (m *Registration) Marshal() (dAtA []byte, err error)
- func (m *Registration) MarshalTo(dAtA []byte) (int, error)
- func (m *Registration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Registration) ProtoMessage()
- func (m *Registration) Reset()
- func (m *Registration) Size() (n int)
- func (this *Registration) String() string
- func (m *Registration) Unmarshal(dAtA []byte) error
- func (this *Registration) VerboseEqual(that interface{}) error
- func (m *Registration) XXX_DiscardUnknown()
- func (m *Registration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Registration) XXX_Merge(src proto.Message)
- func (m *Registration) XXX_Size() int
- func (m *Registration) XXX_Unmarshal(b []byte) error
- type RegistrationRequest
- func (*RegistrationRequest) Descriptor() ([]byte, []int)
- func (this *RegistrationRequest) Equal(that interface{}) bool
- func (m *RegistrationRequest) GetActorList() []Actor
- func (m *RegistrationRequest) GetCSR() string
- func (m *RegistrationRequest) GetName() string
- func (m *RegistrationRequest) GetType() Account_Type
- func (this *RegistrationRequest) GoString() string
- func (m *RegistrationRequest) Marshal() (dAtA []byte, err error)
- func (m *RegistrationRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegistrationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegistrationRequest) ProtoMessage()
- func (m *RegistrationRequest) Reset()
- func (m *RegistrationRequest) Size() (n int)
- func (this *RegistrationRequest) String() string
- func (m *RegistrationRequest) Unmarshal(dAtA []byte) error
- func (this *RegistrationRequest) VerboseEqual(that interface{}) error
- func (m *RegistrationRequest) XXX_DiscardUnknown()
- func (m *RegistrationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegistrationRequest) XXX_Merge(src proto.Message)
- func (m *RegistrationRequest) XXX_Size() int
- func (m *RegistrationRequest) XXX_Unmarshal(b []byte) error
- type Registration_Status
- type SentinelClient
- func (c *SentinelClient) ActorLeaving(actorID string) (err error)
- func (c *SentinelClient) ActorReady(actorID string) (err error)
- func (c *SentinelClient) ListActors(ctx context.Context, cb func(context.Context, ClientGetActorsReply)) error
- func (c *SentinelClient) SurveySubject() string
- func (c *SentinelClient) SurveySubscribe(handler func(SurveyRequest)) (sub *nats.Subscription, err error)
- func (c *SentinelClient) SurveySubscribeChan() (<-chan SurveyRequest, *nats.Subscription, error)
- func (c *SentinelClient) SurveySubscribeSync() (sub *SentinelSurveySubscription, err error)
- type SentinelHandler
- type SentinelServer
- type SentinelSurveySubscription
- type SessionToken
- func (*SessionToken) Descriptor() ([]byte, []int)
- func (this *SessionToken) Equal(that interface{}) bool
- func (m *SessionToken) GetToken() string
- func (m *SessionToken) GetValidUntil() time.Time
- func (this *SessionToken) GoString() string
- func (m *SessionToken) Marshal() (dAtA []byte, err error)
- func (m *SessionToken) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionToken) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionToken) ProtoMessage()
- func (m *SessionToken) Reset()
- func (m *SessionToken) Size() (n int)
- func (this *SessionToken) String() string
- func (m *SessionToken) Unmarshal(dAtA []byte) error
- func (this *SessionToken) VerboseEqual(that interface{}) error
- func (m *SessionToken) XXX_DiscardUnknown()
- func (m *SessionToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionToken) XXX_Merge(src proto.Message)
- func (m *SessionToken) XXX_Size() int
- func (m *SessionToken) XXX_Unmarshal(b []byte) error
- type StringReply
- func (*StringReply) Descriptor() ([]byte, []int)
- func (this *StringReply) Equal(that interface{}) bool
- func (m *StringReply) GetValue() string
- func (this *StringReply) GoString() string
- func (m *StringReply) Marshal() (dAtA []byte, err error)
- func (m *StringReply) MarshalTo(dAtA []byte) (int, error)
- func (m *StringReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StringReply) ProtoMessage()
- func (m *StringReply) Reset()
- func (m *StringReply) Size() (n int)
- func (this *StringReply) String() string
- func (m *StringReply) Unmarshal(dAtA []byte) error
- func (this *StringReply) VerboseEqual(that interface{}) error
- func (m *StringReply) XXX_DiscardUnknown()
- func (m *StringReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StringReply) XXX_Merge(src proto.Message)
- func (m *StringReply) XXX_Size() int
- func (m *StringReply) XXX_Unmarshal(b []byte) error
- type SurveyRequest
- func (*SurveyRequest) Descriptor() ([]byte, []int)
- func (this *SurveyRequest) Equal(that interface{}) bool
- func (m *SurveyRequest) GetOnlineStatus() bool
- func (this *SurveyRequest) GoString() string
- func (m *SurveyRequest) Marshal() (dAtA []byte, err error)
- func (m *SurveyRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SurveyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SurveyRequest) ProtoMessage()
- func (m *SurveyRequest) Reset()
- func (m *SurveyRequest) Size() (n int)
- func (this *SurveyRequest) String() string
- func (m *SurveyRequest) Unmarshal(dAtA []byte) error
- func (this *SurveyRequest) VerboseEqual(that interface{}) error
- func (m *SurveyRequest) XXX_DiscardUnknown()
- func (m *SurveyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SurveyRequest) XXX_Merge(src proto.Message)
- func (m *SurveyRequest) XXX_Size() int
- func (m *SurveyRequest) XXX_Unmarshal(b []byte) error
- type SvcRegistrationClient
- type SvcRegistrationHandler
- type SvcRegistrationServer
- type TimeRange
- func (*TimeRange) Descriptor() ([]byte, []int)
- func (this *TimeRange) Equal(that interface{}) bool
- func (m *TimeRange) GetFrom() *time.Time
- func (m *TimeRange) GetTo() *time.Time
- func (this *TimeRange) GoString() string
- func (m *TimeRange) IsZero() bool
- func (m *TimeRange) Marshal() (dAtA []byte, err error)
- func (m *TimeRange) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeRange) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeRange) ProtoMessage()
- func (m *TimeRange) Reset()
- func (m *TimeRange) Size() (n int)
- func (this *TimeRange) String() string
- func (m *TimeRange) Unmarshal(dAtA []byte) error
- func (this *TimeRange) VerboseEqual(that interface{}) error
- func (m *TimeRange) XXX_DiscardUnknown()
- func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeRange) XXX_Merge(src proto.Message)
- func (m *TimeRange) XXX_Size() int
- func (m *TimeRange) XXX_Unmarshal(b []byte) error
- type UUID
- func (uuid UUID) Compare(other UUID) int
- func (uuid UUID) Equal(other UUID) bool
- func (uuid UUID) IsZero() bool
- func (uuid UUID) Marshal() ([]byte, error)
- func (uuid UUID) MarshalJSON() ([]byte, error)
- func (uuid UUID) MarshalText() ([]byte, error)
- func (uuid UUID) MarshalTo(data []byte) (n int, err error)
- func (uuid *UUID) ReadBytes(str []byte) error
- func (uuid *UUID) SetString(str string) error
- func (uuid *UUID) SetZero()
- func (uuid *UUID) Size() int
- func (uuid UUID) String() string
- func (uuid *UUID) Unmarshal(data []byte) error
- func (uuid *UUID) UnmarshalJSON(data []byte) error
- func (uuid *UUID) UnmarshalText(data []byte) error
- type WhoAmIClient
- type WhoAmIHandler
- type WhoAmIServer
Constants ¶
const ( // XbusAPIPrefix is the common prefix of all the nats subjects of the // xbus API. XbusAPIPrefix = "xbus.default." // ProtocolVersion is the xbus protocol version supported by this // implementation ProtocolVersion = "3.0" )
const ( // ActionCreate is the subject suffix for create operations ActionCreate = "create" // ActionUpdate is the subject suffix for update operations ActionUpdate = "update" // ActionDelete is the subject suffix for delete operations ActionDelete = "delete" // ActionQuery is the subject suffix for query operations ActionQuery = "query" // ServicesPrefix is the prefix for all service specific subjects ServicesPrefix = XbusAPIPrefix + "services." )
const ( // Msgbox is were envelopes are sent Msgbox = XbusAPIPrefix + "msgbox" // DefaultInput is the name of the default input DefaultInput = "default" // DefaultOutput is the name of the default output DefaultOutput = "default" )
const ( // EmissionServicePrefix is the prefix for the emission service EmissionServicePrefix = ServicesPrefix + "emission." // EmissionSignalSubjet is the subject for sending EmissionSignal messages EmissionSignalSubjet = EmissionServicePrefix + "signal" )
const ( // ClientPrefix is the prefix for client api subjects ClientPrefix = XbusAPIPrefix + "client." )
const ( // ProcessStatePrefix is the prefix for process state apis ProcessStatePrefix = XbusAPIPrefix + "processstate." )
const RegistrationSubject = XbusAPIPrefix + "registration"
RegistrationSubject is the subject for registration requests
Variables ¶
var ( ErrInvalidLengthXbus = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowXbus = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupXbus = fmt.Errorf("proto: unexpected end of group") )
var Account_CSROrigin_name = map[int32]string{
0: "ANONYMOUS",
1: "AUTHACCOUNT",
}
var Account_CSROrigin_value = map[string]int32{
"ANONYMOUS": 0,
"AUTHACCOUNT": 1,
}
var Account_Status_name = map[int32]string{
0: "NOSTATUS",
1: "PENDING",
2: "ENABLED",
3: "DISABLED",
}
var Account_Status_value = map[string]int32{
"NOSTATUS": 0,
"PENDING": 1,
"ENABLED": 2,
"DISABLED": 3,
}
var Account_Type_name = map[int32]string{
0: "NOTYPE",
1: "ACTOR",
2: "USER",
3: "GATEWAY",
}
var Account_Type_value = map[string]int32{
"NOTYPE": 0,
"ACTOR": 1,
"USER": 2,
"GATEWAY": 3,
}
var ActorProcessingState_Status_name = map[int32]string{
0: "PENDING",
1: "RUNNING",
2: "SUCCESS",
3: "ERROR",
}
var ActorProcessingState_Status_value = map[string]int32{
"PENDING": 0,
"RUNNING": 1,
"SUCCESS": 2,
"ERROR": 3,
}
var Actor_Kind_name = map[int32]string{
0: "CONSUMER",
1: "EMITTER",
2: "WORKER",
}
var Actor_Kind_value = map[string]int32{
"CONSUMER": 0,
"EMITTER": 1,
"WORKER": 2,
}
var Actor_Status_name = map[int32]string{
0: "PENDING",
1: "ENABLED",
2: "DISABLED",
3: "REJECTED",
}
var Actor_Status_value = map[string]int32{
"PENDING": 0,
"ENABLED": 1,
"DISABLED": 2,
"REJECTED": 3,
}
var EnvelopeAck_ReceptionStatus_name = map[int32]string{
0: "NOSTATUS",
1: "RECEIVING",
2: "ACCEPTED",
3: "ERROR",
}
var EnvelopeAck_ReceptionStatus_value = map[string]int32{
"NOSTATUS": 0,
"RECEIVING": 1,
"ACCEPTED": 2,
"ERROR": 3,
}
var EnvelopeEvent_Status_name = map[int32]string{
0: "UNKNOWN",
1: "RECEIVING",
3: "COMPLETE",
4: "ERROR",
5: "STALLED",
}
var EnvelopeEvent_Status_value = map[string]int32{
"UNKNOWN": 0,
"RECEIVING": 1,
"COMPLETE": 3,
"ERROR": 4,
"STALLED": 5,
}
var ( // EnvelopeMaxSize is an approximate maximum size of an envelope // A single Envelope should never exceed this size, or it could be // rejected by nats EnvelopeMaxSize = 750 * 1024 // 750K encrypted should be smaller than 1M )
var LogLevel_name = map[int32]string{
0: "NOTICE",
1: "WARNING",
2: "ERROR",
}
var LogLevel_value = map[string]int32{
"NOTICE": 0,
"WARNING": 1,
"ERROR": 2,
}
var PMProcess_Status_name = map[int32]string{
0: "DEFAULT",
1: "NEW",
2: "OPENED",
3: "CLOSED",
}
var PMProcess_Status_value = map[string]int32{
"DEFAULT": 0,
"NEW": 1,
"OPENED": 2,
"CLOSED": 3,
}
var PipelineInfo_Status_name = map[int32]string{
0: "DRAFT",
1: "ACTIVE",
2: "INACTIVE",
}
var PipelineInfo_Status_value = map[string]int32{
"DRAFT": 0,
"ACTIVE": 1,
"INACTIVE": 2,
}
var Process_Status_name = map[int32]string{
0: "NOSTATUS",
1: "INITIAL",
2: "RUNNING",
3: "PAUSED",
4: "DONE",
5: "ERROR",
}
var Process_Status_value = map[string]int32{
"NOSTATUS": 0,
"INITIAL": 1,
"RUNNING": 2,
"PAUSED": 3,
"DONE": 4,
"ERROR": 5,
}
var Registration_Status_name = map[int32]string{
0: "PENDING",
1: "ACCEPTED",
2: "REJECTED",
}
var Registration_Status_value = map[string]int32{
"PENDING": 0,
"ACCEPTED": 1,
"REJECTED": 2,
}
Functions ¶
func ActorInputSubject ¶
ActorInputSubject returns the subject for an actor input
func ActorOutputSubject ¶
ActorOutputSubject returns the subject for an actor output
func ClientProtoError ¶
ClientProtoError returns a client error nrpc.Error
func EmitterEnvelopeStateSubject ¶
EmitterEnvelopeStateSubject returns the subject on which process events are sent
func EmitterMsgboxSubject ¶
EmitterMsgboxSubject returns the msgbox for an emitter
func ItemsAsChunks ¶
ItemsAsChunks converts a slice of items into a slice of data chunks
func JSONMarshal ¶
func JSONMarshal(encodings []ItemEncoding, pb proto.Message) ([]byte, error)
JSONMarshal encodes api messages to JSON. The encodings list controls how the api.Item will be encoded
func ServerProtoError ¶
ServerProtoError returns a server error nrpc.Error
func UUIDToStringOrWildcard ¶
UUIDToStringOrWildcard return '*' if the value is zero, and the value.String() result otherwise
func WhoAmISubjects ¶
WhoAmISubjects returns the subject/reply subjects for a WhoAmI req/rep
Types ¶
type Account ¶
type Account struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` /// Account name Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` /// Account type Type Account_Type `protobuf:"varint,3,opt,name=type,proto3,enum=xbus.Account_Type" json:"type,omitempty"` /// Account status Status Account_Status `protobuf:"varint,4,opt,name=status,proto3,enum=xbus.Account_Status" json:"status,omitempty"` /// The certificate signing request CSR string `protobuf:"bytes,5,opt,name=csr,proto3" json:"csr,omitempty"` CSROrigin Account_CSROrigin `protobuf:"varint,8,opt,name=csrOrigin,proto3,enum=xbus.Account_CSROrigin" json:"csrOrigin,omitempty"` /// The account certificate Cert string `protobuf:"bytes,6,opt,name=cert,proto3" json:"cert,omitempty"` // The account api key APIKey string `protobuf:"bytes,7,opt,name=apiKey,proto3" json:"apiKey,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedAccount ¶
func (*Account) Descriptor ¶
func (*Account) GetCSROrigin ¶
func (m *Account) GetCSROrigin() Account_CSROrigin
func (*Account) GetStatus ¶
func (m *Account) GetStatus() Account_Status
func (*Account) GetType ¶
func (m *Account) GetType() Account_Type
func (*Account) MarshalToSizedBuffer ¶
func (*Account) ProtoMessage ¶
func (*Account) ProtoMessage()
func (*Account) VerboseEqual ¶
func (*Account) XXX_DiscardUnknown ¶
func (m *Account) XXX_DiscardUnknown()
func (*Account) XXX_Marshal ¶
func (*Account) XXX_Unmarshal ¶
type Account_CSROrigin ¶
type Account_CSROrigin int32
const ( Account_ANONYMOUS Account_CSROrigin = 0 Account_AUTHACCOUNT Account_CSROrigin = 1 )
func (Account_CSROrigin) EnumDescriptor ¶
func (Account_CSROrigin) EnumDescriptor() ([]byte, []int)
func (Account_CSROrigin) MarshalText ¶
func (e Account_CSROrigin) MarshalText() ([]byte, error)
MarshalText serialize a Account_CSROrigin
func (Account_CSROrigin) String ¶
func (x Account_CSROrigin) String() string
func (*Account_CSROrigin) UnmarshalText ¶
func (e *Account_CSROrigin) UnmarshalText(data []byte) error
UnmarshalText parses a Account_CSROrigin string
type Account_Status ¶
type Account_Status int32
const ( Account_NOSTATUS Account_Status = 0 Account_PENDING Account_Status = 1 Account_ENABLED Account_Status = 2 Account_DISABLED Account_Status = 3 )
func (Account_Status) EnumDescriptor ¶
func (Account_Status) EnumDescriptor() ([]byte, []int)
func (Account_Status) MarshalText ¶
func (e Account_Status) MarshalText() ([]byte, error)
MarshalText serialize a Account_Status
func (Account_Status) String ¶
func (x Account_Status) String() string
func (*Account_Status) UnmarshalText ¶
func (e *Account_Status) UnmarshalText(data []byte) error
UnmarshalText parses a Account_Status string
type Account_Type ¶
type Account_Type int32
const ( Account_NOTYPE Account_Type = 0 Account_ACTOR Account_Type = 1 Account_USER Account_Type = 2 Account_GATEWAY Account_Type = 3 )
func (Account_Type) EnumDescriptor ¶
func (Account_Type) EnumDescriptor() ([]byte, []int)
func (Account_Type) MarshalText ¶
func (e Account_Type) MarshalText() ([]byte, error)
MarshalText serialize a Account_Type
func (Account_Type) String ¶
func (x Account_Type) String() string
func (*Account_Type) UnmarshalText ¶
func (e *Account_Type) UnmarshalText(data []byte) error
UnmarshalText parses a Account_Type string
type AckResultRequest ¶
type AckResultRequest struct { ProcessID UUID `protobuf:"bytes,1,opt,name=process_id,json=processId,proto3,customtype=UUID" json:"process_id"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedAckResultRequest ¶
func NewPopulatedAckResultRequest(r randyXbus, easy bool) *AckResultRequest
func (*AckResultRequest) Descriptor ¶
func (*AckResultRequest) Descriptor() ([]byte, []int)
func (*AckResultRequest) Equal ¶
func (this *AckResultRequest) Equal(that interface{}) bool
func (*AckResultRequest) GoString ¶
func (this *AckResultRequest) GoString() string
func (*AckResultRequest) Marshal ¶
func (m *AckResultRequest) Marshal() (dAtA []byte, err error)
func (*AckResultRequest) MarshalToSizedBuffer ¶
func (m *AckResultRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AckResultRequest) ProtoMessage ¶
func (*AckResultRequest) ProtoMessage()
func (*AckResultRequest) Reset ¶
func (m *AckResultRequest) Reset()
func (*AckResultRequest) Size ¶
func (m *AckResultRequest) Size() (n int)
func (*AckResultRequest) String ¶
func (this *AckResultRequest) String() string
func (*AckResultRequest) Unmarshal ¶
func (m *AckResultRequest) Unmarshal(dAtA []byte) error
func (*AckResultRequest) VerboseEqual ¶
func (this *AckResultRequest) VerboseEqual(that interface{}) error
func (*AckResultRequest) XXX_DiscardUnknown ¶
func (m *AckResultRequest) XXX_DiscardUnknown()
func (*AckResultRequest) XXX_Marshal ¶
func (m *AckResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AckResultRequest) XXX_Merge ¶
func (m *AckResultRequest) XXX_Merge(src proto.Message)
func (*AckResultRequest) XXX_Size ¶
func (m *AckResultRequest) XXX_Size() int
func (*AckResultRequest) XXX_Unmarshal ¶
func (m *AckResultRequest) XXX_Unmarshal(b []byte) error
type Actor ¶
type Actor struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Kind Actor_Kind `protobuf:"varint,3,opt,name=kind,proto3,enum=xbus.Actor_Kind" json:"kind,omitempty"` Status Actor_Status `protobuf:"varint,4,opt,name=status,proto3,enum=xbus.Actor_Status" json:"status,omitempty"` AccountID UUID `protobuf:"bytes,5,opt,name=accountID,proto3,customtype=UUID" json:"accountID"` Roles []string `protobuf:"bytes,6,rep,name=roles,proto3" json:"roles,omitempty"` LastSeen time.Time `protobuf:"bytes,8,opt,name=lastSeen,proto3,stdtime" json:"lastSeen"` Online bool `protobuf:"varint,9,opt,name=online,proto3" json:"online,omitempty"` Unresponsive bool `protobuf:"varint,10,opt,name=unresponsive,proto3" json:"unresponsive,omitempty"` Config []ConfigEntry `protobuf:"bytes,11,rep,name=config,proto3" json:"config"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActor ¶
func (*Actor) Descriptor ¶
func (*Actor) GetConfig ¶
func (m *Actor) GetConfig() []ConfigEntry
func (*Actor) GetConfigEntry ¶
GetConfigEntry returns the value of the given entry, or "" if it does not exist
func (*Actor) GetKind ¶
func (m *Actor) GetKind() Actor_Kind
func (*Actor) GetLastSeen ¶
func (*Actor) GetStatus ¶
func (m *Actor) GetStatus() Actor_Status
func (*Actor) GetUnresponsive ¶
func (*Actor) ProtoMessage ¶
func (*Actor) ProtoMessage()
func (*Actor) VerboseEqual ¶
func (*Actor) XXX_DiscardUnknown ¶
func (m *Actor) XXX_DiscardUnknown()
func (*Actor) XXX_Marshal ¶
func (*Actor) XXX_Unmarshal ¶
type ActorAgentClient ¶
type ActorAgentClient struct { PkgSubject string Subject string SvcParamactorID string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewActorAgentClient ¶
func NewActorAgentClient(nc nrpc.NatsConn, svcParamactorID string) *ActorAgentClient
func (*ActorAgentClient) Process ¶
func (c *ActorAgentClient) Process( ctx context.Context, req ActorProcessRequest, cb func(context.Context, ActorProcessingState), ) error
type ActorAgentHandler ¶
type ActorAgentHandler struct {
// contains filtered or unexported fields
}
ActorAgentHandler provides a NATS subscription handler that can serve a subscription using a given ActorAgentServer implementation.
func NewActorAgentConcurrentHandler ¶
func NewActorAgentConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ActorAgentServer) *ActorAgentHandler
func NewActorAgentHandler ¶
func NewActorAgentHandler(ctx context.Context, nc nrpc.NatsConn, s ActorAgentServer) *ActorAgentHandler
func (*ActorAgentHandler) Handler ¶
func (h *ActorAgentHandler) Handler(msg *nats.Msg)
func (*ActorAgentHandler) SetEncodings ¶
func (h *ActorAgentHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*ActorAgentHandler) Subject ¶
func (h *ActorAgentHandler) Subject() string
type ActorAgentServer ¶
type ActorAgentServer interface {
Process(ctx context.Context, req ActorProcessRequest, pushRep func(ActorProcessingState)) (err error)
}
ActorAgentServer is the interface that providers of the service ActorAgent should implement.
type ActorLogRequest ¶
type ActorLogRequest struct { EnvelopeID *UUID `protobuf:"bytes,1,opt,name=envelopeID,proto3,customtype=UUID" json:"envelopeID,omitempty"` Context *ProcessingContext `protobuf:"bytes,2,opt,name=Context,proto3" json:"Context,omitempty"` Messages []LogMessage `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActorLogRequest ¶
func NewPopulatedActorLogRequest(r randyXbus, easy bool) *ActorLogRequest
func (*ActorLogRequest) Descriptor ¶
func (*ActorLogRequest) Descriptor() ([]byte, []int)
func (*ActorLogRequest) Equal ¶
func (this *ActorLogRequest) Equal(that interface{}) bool
func (*ActorLogRequest) GetContext ¶
func (m *ActorLogRequest) GetContext() *ProcessingContext
func (*ActorLogRequest) GetMessages ¶
func (m *ActorLogRequest) GetMessages() []LogMessage
func (*ActorLogRequest) GoString ¶
func (this *ActorLogRequest) GoString() string
func (*ActorLogRequest) Marshal ¶
func (m *ActorLogRequest) Marshal() (dAtA []byte, err error)
func (*ActorLogRequest) MarshalToSizedBuffer ¶
func (m *ActorLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActorLogRequest) ProtoMessage ¶
func (*ActorLogRequest) ProtoMessage()
func (*ActorLogRequest) Reset ¶
func (m *ActorLogRequest) Reset()
func (*ActorLogRequest) Size ¶
func (m *ActorLogRequest) Size() (n int)
func (*ActorLogRequest) String ¶
func (this *ActorLogRequest) String() string
func (*ActorLogRequest) Unmarshal ¶
func (m *ActorLogRequest) Unmarshal(dAtA []byte) error
func (*ActorLogRequest) VerboseEqual ¶
func (this *ActorLogRequest) VerboseEqual(that interface{}) error
func (*ActorLogRequest) XXX_DiscardUnknown ¶
func (m *ActorLogRequest) XXX_DiscardUnknown()
func (*ActorLogRequest) XXX_Marshal ¶
func (m *ActorLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorLogRequest) XXX_Merge ¶
func (m *ActorLogRequest) XXX_Merge(src proto.Message)
func (*ActorLogRequest) XXX_Size ¶
func (m *ActorLogRequest) XXX_Size() int
func (*ActorLogRequest) XXX_Unmarshal ¶
func (m *ActorLogRequest) XXX_Unmarshal(b []byte) error
type ActorProcessRequest ¶
type ActorProcessRequest struct { Context *ProcessingContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Inputs []*ActorProcessRequest_Input `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActorProcessRequest ¶
func NewPopulatedActorProcessRequest(r randyXbus, easy bool) *ActorProcessRequest
func (*ActorProcessRequest) Descriptor ¶
func (*ActorProcessRequest) Descriptor() ([]byte, []int)
func (*ActorProcessRequest) Equal ¶
func (this *ActorProcessRequest) Equal(that interface{}) bool
func (*ActorProcessRequest) GetContext ¶
func (m *ActorProcessRequest) GetContext() *ProcessingContext
func (*ActorProcessRequest) GetInputs ¶
func (m *ActorProcessRequest) GetInputs() []*ActorProcessRequest_Input
func (*ActorProcessRequest) GoString ¶
func (this *ActorProcessRequest) GoString() string
func (*ActorProcessRequest) Marshal ¶
func (m *ActorProcessRequest) Marshal() (dAtA []byte, err error)
func (*ActorProcessRequest) MarshalTo ¶
func (m *ActorProcessRequest) MarshalTo(dAtA []byte) (int, error)
func (*ActorProcessRequest) MarshalToSizedBuffer ¶
func (m *ActorProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActorProcessRequest) ProtoMessage ¶
func (*ActorProcessRequest) ProtoMessage()
func (*ActorProcessRequest) Reset ¶
func (m *ActorProcessRequest) Reset()
func (*ActorProcessRequest) Size ¶
func (m *ActorProcessRequest) Size() (n int)
func (*ActorProcessRequest) String ¶
func (this *ActorProcessRequest) String() string
func (*ActorProcessRequest) Unmarshal ¶
func (m *ActorProcessRequest) Unmarshal(dAtA []byte) error
func (*ActorProcessRequest) VerboseEqual ¶
func (this *ActorProcessRequest) VerboseEqual(that interface{}) error
func (*ActorProcessRequest) XXX_DiscardUnknown ¶
func (m *ActorProcessRequest) XXX_DiscardUnknown()
func (*ActorProcessRequest) XXX_Marshal ¶
func (m *ActorProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorProcessRequest) XXX_Merge ¶
func (m *ActorProcessRequest) XXX_Merge(src proto.Message)
func (*ActorProcessRequest) XXX_Size ¶
func (m *ActorProcessRequest) XXX_Size() int
func (*ActorProcessRequest) XXX_Unmarshal ¶
func (m *ActorProcessRequest) XXX_Unmarshal(b []byte) error
type ActorProcessRequest_Input ¶
type ActorProcessRequest_Input struct { // Name of the input Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // True if no envelope to expect Close bool `protobuf:"varint,2,opt,name=close,proto3" json:"close,omitempty"` // First envelope fragment if available Envelope *Envelope `protobuf:"bytes,3,opt,name=envelope,proto3" json:"envelope,omitempty"` // Envelope position Position *EnvelopePosition `protobuf:"bytes,4,opt,name=position,proto3" json:"position,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActorProcessRequest_Input ¶
func NewPopulatedActorProcessRequest_Input(r randyXbus, easy bool) *ActorProcessRequest_Input
func (*ActorProcessRequest_Input) Descriptor ¶
func (*ActorProcessRequest_Input) Descriptor() ([]byte, []int)
func (*ActorProcessRequest_Input) Equal ¶
func (this *ActorProcessRequest_Input) Equal(that interface{}) bool
func (*ActorProcessRequest_Input) GetClose ¶
func (m *ActorProcessRequest_Input) GetClose() bool
func (*ActorProcessRequest_Input) GetEnvelope ¶
func (m *ActorProcessRequest_Input) GetEnvelope() *Envelope
func (*ActorProcessRequest_Input) GetName ¶
func (m *ActorProcessRequest_Input) GetName() string
func (*ActorProcessRequest_Input) GetPosition ¶
func (m *ActorProcessRequest_Input) GetPosition() *EnvelopePosition
func (*ActorProcessRequest_Input) GoString ¶
func (this *ActorProcessRequest_Input) GoString() string
func (*ActorProcessRequest_Input) Marshal ¶
func (m *ActorProcessRequest_Input) Marshal() (dAtA []byte, err error)
func (*ActorProcessRequest_Input) MarshalTo ¶
func (m *ActorProcessRequest_Input) MarshalTo(dAtA []byte) (int, error)
func (*ActorProcessRequest_Input) MarshalToSizedBuffer ¶
func (m *ActorProcessRequest_Input) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActorProcessRequest_Input) ProtoMessage ¶
func (*ActorProcessRequest_Input) ProtoMessage()
func (*ActorProcessRequest_Input) Reset ¶
func (m *ActorProcessRequest_Input) Reset()
func (*ActorProcessRequest_Input) Size ¶
func (m *ActorProcessRequest_Input) Size() (n int)
func (*ActorProcessRequest_Input) String ¶
func (this *ActorProcessRequest_Input) String() string
func (*ActorProcessRequest_Input) Unmarshal ¶
func (m *ActorProcessRequest_Input) Unmarshal(dAtA []byte) error
func (*ActorProcessRequest_Input) VerboseEqual ¶
func (this *ActorProcessRequest_Input) VerboseEqual(that interface{}) error
func (*ActorProcessRequest_Input) XXX_DiscardUnknown ¶
func (m *ActorProcessRequest_Input) XXX_DiscardUnknown()
func (*ActorProcessRequest_Input) XXX_Marshal ¶
func (m *ActorProcessRequest_Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorProcessRequest_Input) XXX_Merge ¶
func (m *ActorProcessRequest_Input) XXX_Merge(src proto.Message)
func (*ActorProcessRequest_Input) XXX_Size ¶
func (m *ActorProcessRequest_Input) XXX_Size() int
func (*ActorProcessRequest_Input) XXX_Unmarshal ¶
func (m *ActorProcessRequest_Input) XXX_Unmarshal(b []byte) error
type ActorProcessingState ¶
type ActorProcessingState struct { Context ProcessingContext `protobuf:"bytes,2,opt,name=context,proto3" json:"context"` Status ActorProcessingState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=xbus.ActorProcessingState_Status" json:"status,omitempty"` Messages []LogMessage `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages"` ActorLeaving bool `protobuf:"varint,5,opt,name=ActorLeaving,proto3" json:"ActorLeaving,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActorProcessingState ¶
func NewPopulatedActorProcessingState(r randyXbus, easy bool) *ActorProcessingState
func (*ActorProcessingState) Descriptor ¶
func (*ActorProcessingState) Descriptor() ([]byte, []int)
func (*ActorProcessingState) Equal ¶
func (this *ActorProcessingState) Equal(that interface{}) bool
func (*ActorProcessingState) GetActorLeaving ¶
func (m *ActorProcessingState) GetActorLeaving() bool
func (*ActorProcessingState) GetContext ¶
func (m *ActorProcessingState) GetContext() ProcessingContext
func (*ActorProcessingState) GetMessages ¶
func (m *ActorProcessingState) GetMessages() []LogMessage
func (*ActorProcessingState) GetStatus ¶
func (m *ActorProcessingState) GetStatus() ActorProcessingState_Status
func (*ActorProcessingState) GoString ¶
func (this *ActorProcessingState) GoString() string
func (*ActorProcessingState) Marshal ¶
func (m *ActorProcessingState) Marshal() (dAtA []byte, err error)
func (*ActorProcessingState) MarshalTo ¶
func (m *ActorProcessingState) MarshalTo(dAtA []byte) (int, error)
func (*ActorProcessingState) MarshalToSizedBuffer ¶
func (m *ActorProcessingState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActorProcessingState) ProtoMessage ¶
func (*ActorProcessingState) ProtoMessage()
func (*ActorProcessingState) Reset ¶
func (m *ActorProcessingState) Reset()
func (*ActorProcessingState) Size ¶
func (m *ActorProcessingState) Size() (n int)
func (*ActorProcessingState) String ¶
func (this *ActorProcessingState) String() string
func (*ActorProcessingState) Unmarshal ¶
func (m *ActorProcessingState) Unmarshal(dAtA []byte) error
func (*ActorProcessingState) VerboseEqual ¶
func (this *ActorProcessingState) VerboseEqual(that interface{}) error
func (*ActorProcessingState) XXX_DiscardUnknown ¶
func (m *ActorProcessingState) XXX_DiscardUnknown()
func (*ActorProcessingState) XXX_Marshal ¶
func (m *ActorProcessingState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorProcessingState) XXX_Merge ¶
func (m *ActorProcessingState) XXX_Merge(src proto.Message)
func (*ActorProcessingState) XXX_Size ¶
func (m *ActorProcessingState) XXX_Size() int
func (*ActorProcessingState) XXX_Unmarshal ¶
func (m *ActorProcessingState) XXX_Unmarshal(b []byte) error
type ActorProcessingState_Status ¶
type ActorProcessingState_Status int32
const ( ActorProcessingState_PENDING ActorProcessingState_Status = 0 ActorProcessingState_RUNNING ActorProcessingState_Status = 1 ActorProcessingState_SUCCESS ActorProcessingState_Status = 2 ActorProcessingState_ERROR ActorProcessingState_Status = 3 )
func (ActorProcessingState_Status) EnumDescriptor ¶
func (ActorProcessingState_Status) EnumDescriptor() ([]byte, []int)
func (ActorProcessingState_Status) MarshalText ¶
func (e ActorProcessingState_Status) MarshalText() ([]byte, error)
MarshalText serialize a ActorProcessingState_Status
func (ActorProcessingState_Status) String ¶
func (x ActorProcessingState_Status) String() string
func (*ActorProcessingState_Status) UnmarshalText ¶
func (e *ActorProcessingState_Status) UnmarshalText(data []byte) error
UnmarshalText parses a ActorProcessingState_Status string
type ActorReadyMsg ¶
type ActorReadyMsg struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedActorReadyMsg ¶
func NewPopulatedActorReadyMsg(r randyXbus, easy bool) *ActorReadyMsg
func (*ActorReadyMsg) Descriptor ¶
func (*ActorReadyMsg) Descriptor() ([]byte, []int)
func (*ActorReadyMsg) Equal ¶
func (this *ActorReadyMsg) Equal(that interface{}) bool
func (*ActorReadyMsg) GoString ¶
func (this *ActorReadyMsg) GoString() string
func (*ActorReadyMsg) Marshal ¶
func (m *ActorReadyMsg) Marshal() (dAtA []byte, err error)
func (*ActorReadyMsg) MarshalToSizedBuffer ¶
func (m *ActorReadyMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActorReadyMsg) ProtoMessage ¶
func (*ActorReadyMsg) ProtoMessage()
func (*ActorReadyMsg) Reset ¶
func (m *ActorReadyMsg) Reset()
func (*ActorReadyMsg) Size ¶
func (m *ActorReadyMsg) Size() (n int)
func (*ActorReadyMsg) String ¶
func (this *ActorReadyMsg) String() string
func (*ActorReadyMsg) Unmarshal ¶
func (m *ActorReadyMsg) Unmarshal(dAtA []byte) error
func (*ActorReadyMsg) VerboseEqual ¶
func (this *ActorReadyMsg) VerboseEqual(that interface{}) error
func (*ActorReadyMsg) XXX_DiscardUnknown ¶
func (m *ActorReadyMsg) XXX_DiscardUnknown()
func (*ActorReadyMsg) XXX_Marshal ¶
func (m *ActorReadyMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorReadyMsg) XXX_Merge ¶
func (m *ActorReadyMsg) XXX_Merge(src proto.Message)
func (*ActorReadyMsg) XXX_Size ¶
func (m *ActorReadyMsg) XXX_Size() int
func (*ActorReadyMsg) XXX_Unmarshal ¶
func (m *ActorReadyMsg) XXX_Unmarshal(b []byte) error
type Actor_Kind ¶
type Actor_Kind int32
const ( Actor_CONSUMER Actor_Kind = 0 Actor_EMITTER Actor_Kind = 1 Actor_WORKER Actor_Kind = 2 )
func (Actor_Kind) EnumDescriptor ¶
func (Actor_Kind) EnumDescriptor() ([]byte, []int)
func (Actor_Kind) MarshalText ¶
func (e Actor_Kind) MarshalText() ([]byte, error)
MarshalText serialize a Actor_Kind
func (Actor_Kind) String ¶
func (x Actor_Kind) String() string
func (*Actor_Kind) UnmarshalText ¶
func (e *Actor_Kind) UnmarshalText(data []byte) error
UnmarshalText parses a Actor_Kind string
type Actor_Status ¶
type Actor_Status int32
const ( Actor_PENDING Actor_Status = 0 Actor_ENABLED Actor_Status = 1 Actor_DISABLED Actor_Status = 2 Actor_REJECTED Actor_Status = 3 )
func (Actor_Status) EnumDescriptor ¶
func (Actor_Status) EnumDescriptor() ([]byte, []int)
func (Actor_Status) MarshalText ¶
func (e Actor_Status) MarshalText() ([]byte, error)
MarshalText serialize a Actor_Status
func (Actor_Status) String ¶
func (x Actor_Status) String() string
func (*Actor_Status) UnmarshalText ¶
func (e *Actor_Status) UnmarshalText(data []byte) error
UnmarshalText parses a Actor_Status string
type BrokerClient ¶
type BrokerClient struct { PkgSubject string Subject string SvcParamactorID string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewBrokerClient ¶
func NewBrokerClient(nc nrpc.NatsConn, svcParamactorID string) *BrokerClient
func (*BrokerClient) Output ¶
func (c *BrokerClient) Output(req OutputRequest) (resp EnvelopeAck, err error)
type BrokerHandler ¶
type BrokerHandler struct {
// contains filtered or unexported fields
}
BrokerHandler provides a NATS subscription handler that can serve a subscription using a given BrokerServer implementation.
func NewBrokerConcurrentHandler ¶
func NewBrokerConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s BrokerServer) *BrokerHandler
func NewBrokerHandler ¶
func NewBrokerHandler(ctx context.Context, nc nrpc.NatsConn, s BrokerServer) *BrokerHandler
func (*BrokerHandler) Handler ¶
func (h *BrokerHandler) Handler(msg *nats.Msg)
func (*BrokerHandler) SetEncodings ¶
func (h *BrokerHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*BrokerHandler) Subject ¶
func (h *BrokerHandler) Subject() string
type BrokerServer ¶
type BrokerServer interface {
Output(ctx context.Context, req OutputRequest) (resp EnvelopeAck, err error)
}
BrokerServer is the interface that providers of the service Broker should implement.
type Client ¶
type Client struct { Director *DirectorClient EnvelopeStorage *EnvelopeStorageClient ClientAPI *ClientAPIClient WhoAmI *WhoAmIClient ProcessState *ProcessStateClient ActorAgent *ActorAgentClient Broker *BrokerClient CoreEvents *CoreEventsClient SvcRegistration *SvcRegistrationClient Sentinel *SentinelClient // contains filtered or unexported fields }
func (*Client) NewActorAgent ¶
func (c *Client) NewActorAgent( actorID string, ) *ActorAgentClient
func (*Client) NewBroker ¶
func (c *Client) NewBroker( actorID string, ) *BrokerClient
func (*Client) NewClientAPI ¶
func (c *Client) NewClientAPI( accountID string, ) *ClientAPIClient
func (*Client) SetActorAgentParams ¶
func (*Client) SetBrokerParams ¶
func (*Client) SetClientAPIParams ¶
func (*Client) SetEncoding ¶
func (*Client) SetTimeout ¶
type ClientAPIClient ¶
type ClientAPIClient struct { PkgSubject string Subject string SvcParamaccountID string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewClientAPIClient ¶
func NewClientAPIClient(nc nrpc.NatsConn, svcParamaccountID string) *ClientAPIClient
func (*ClientAPIClient) GetActors ¶
func (c *ClientAPIClient) GetActors() (resp ClientGetActorsReply, err error)
func (*ClientAPIClient) GetSessionToken ¶
func (c *ClientAPIClient) GetSessionToken(req GetSessionTokenRequest) (resp SessionToken, err error)
type ClientAPIHandler ¶
type ClientAPIHandler struct {
// contains filtered or unexported fields
}
ClientAPIHandler provides a NATS subscription handler that can serve a subscription using a given ClientAPIServer implementation.
func NewClientAPIConcurrentHandler ¶
func NewClientAPIConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ClientAPIServer) *ClientAPIHandler
func NewClientAPIHandler ¶
func NewClientAPIHandler(ctx context.Context, nc nrpc.NatsConn, s ClientAPIServer) *ClientAPIHandler
func (*ClientAPIHandler) Handler ¶
func (h *ClientAPIHandler) Handler(msg *nats.Msg)
func (*ClientAPIHandler) SetEncodings ¶
func (h *ClientAPIHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*ClientAPIHandler) Subject ¶
func (h *ClientAPIHandler) Subject() string
type ClientAPIServer ¶
type ClientAPIServer interface { GetActors(ctx context.Context) (resp ClientGetActorsReply, err error) GetSessionToken(ctx context.Context, req GetSessionTokenRequest) (resp SessionToken, err error) }
ClientAPIServer is the interface that providers of the service ClientAPI should implement.
type ClientGetActorsReply ¶
type ClientGetActorsReply struct { Actors []Actor `protobuf:"bytes,1,rep,name=actors,proto3" json:"actors"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedClientGetActorsReply ¶
func NewPopulatedClientGetActorsReply(r randyXbus, easy bool) *ClientGetActorsReply
func (*ClientGetActorsReply) Descriptor ¶
func (*ClientGetActorsReply) Descriptor() ([]byte, []int)
func (*ClientGetActorsReply) Equal ¶
func (this *ClientGetActorsReply) Equal(that interface{}) bool
func (*ClientGetActorsReply) GetActors ¶
func (m *ClientGetActorsReply) GetActors() []Actor
func (*ClientGetActorsReply) GoString ¶
func (this *ClientGetActorsReply) GoString() string
func (*ClientGetActorsReply) Marshal ¶
func (m *ClientGetActorsReply) Marshal() (dAtA []byte, err error)
func (*ClientGetActorsReply) MarshalTo ¶
func (m *ClientGetActorsReply) MarshalTo(dAtA []byte) (int, error)
func (*ClientGetActorsReply) MarshalToSizedBuffer ¶
func (m *ClientGetActorsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientGetActorsReply) ProtoMessage ¶
func (*ClientGetActorsReply) ProtoMessage()
func (*ClientGetActorsReply) Reset ¶
func (m *ClientGetActorsReply) Reset()
func (*ClientGetActorsReply) Size ¶
func (m *ClientGetActorsReply) Size() (n int)
func (*ClientGetActorsReply) String ¶
func (this *ClientGetActorsReply) String() string
func (*ClientGetActorsReply) Unmarshal ¶
func (m *ClientGetActorsReply) Unmarshal(dAtA []byte) error
func (*ClientGetActorsReply) VerboseEqual ¶
func (this *ClientGetActorsReply) VerboseEqual(that interface{}) error
func (*ClientGetActorsReply) XXX_DiscardUnknown ¶
func (m *ClientGetActorsReply) XXX_DiscardUnknown()
func (*ClientGetActorsReply) XXX_Marshal ¶
func (m *ClientGetActorsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientGetActorsReply) XXX_Merge ¶
func (m *ClientGetActorsReply) XXX_Merge(src proto.Message)
func (*ClientGetActorsReply) XXX_Size ¶
func (m *ClientGetActorsReply) XXX_Size() int
func (*ClientGetActorsReply) XXX_Unmarshal ¶
func (m *ClientGetActorsReply) XXX_Unmarshal(b []byte) error
type ClientGetActorsRequest ¶
type ClientGetActorsRequest struct { ActorID UUID `protobuf:"bytes,1,opt,name=actorID,proto3,customtype=UUID" json:"actorID"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedClientGetActorsRequest ¶
func NewPopulatedClientGetActorsRequest(r randyXbus, easy bool) *ClientGetActorsRequest
func (*ClientGetActorsRequest) Descriptor ¶
func (*ClientGetActorsRequest) Descriptor() ([]byte, []int)
func (*ClientGetActorsRequest) Equal ¶
func (this *ClientGetActorsRequest) Equal(that interface{}) bool
func (*ClientGetActorsRequest) GoString ¶
func (this *ClientGetActorsRequest) GoString() string
func (*ClientGetActorsRequest) Marshal ¶
func (m *ClientGetActorsRequest) Marshal() (dAtA []byte, err error)
func (*ClientGetActorsRequest) MarshalTo ¶
func (m *ClientGetActorsRequest) MarshalTo(dAtA []byte) (int, error)
func (*ClientGetActorsRequest) MarshalToSizedBuffer ¶
func (m *ClientGetActorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientGetActorsRequest) ProtoMessage ¶
func (*ClientGetActorsRequest) ProtoMessage()
func (*ClientGetActorsRequest) Reset ¶
func (m *ClientGetActorsRequest) Reset()
func (*ClientGetActorsRequest) Size ¶
func (m *ClientGetActorsRequest) Size() (n int)
func (*ClientGetActorsRequest) String ¶
func (this *ClientGetActorsRequest) String() string
func (*ClientGetActorsRequest) Unmarshal ¶
func (m *ClientGetActorsRequest) Unmarshal(dAtA []byte) error
func (*ClientGetActorsRequest) VerboseEqual ¶
func (this *ClientGetActorsRequest) VerboseEqual(that interface{}) error
func (*ClientGetActorsRequest) XXX_DiscardUnknown ¶
func (m *ClientGetActorsRequest) XXX_DiscardUnknown()
func (*ClientGetActorsRequest) XXX_Marshal ¶
func (m *ClientGetActorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientGetActorsRequest) XXX_Merge ¶
func (m *ClientGetActorsRequest) XXX_Merge(src proto.Message)
func (*ClientGetActorsRequest) XXX_Size ¶
func (m *ClientGetActorsRequest) XXX_Size() int
func (*ClientGetActorsRequest) XXX_Unmarshal ¶
func (m *ClientGetActorsRequest) XXX_Unmarshal(b []byte) error
type ConfigEntry ¶
type ConfigEntry struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
*
func NewPopulatedConfigEntry ¶
func NewPopulatedConfigEntry(r randyXbus, easy bool) *ConfigEntry
func (*ConfigEntry) Descriptor ¶
func (*ConfigEntry) Descriptor() ([]byte, []int)
func (*ConfigEntry) Equal ¶
func (this *ConfigEntry) Equal(that interface{}) bool
func (*ConfigEntry) GetKey ¶
func (m *ConfigEntry) GetKey() string
func (*ConfigEntry) GetValue ¶
func (m *ConfigEntry) GetValue() string
func (*ConfigEntry) GoString ¶
func (this *ConfigEntry) GoString() string
func (*ConfigEntry) Marshal ¶
func (m *ConfigEntry) Marshal() (dAtA []byte, err error)
func (*ConfigEntry) MarshalToSizedBuffer ¶
func (m *ConfigEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigEntry) ProtoMessage ¶
func (*ConfigEntry) ProtoMessage()
func (*ConfigEntry) Reset ¶
func (m *ConfigEntry) Reset()
func (*ConfigEntry) Size ¶
func (m *ConfigEntry) Size() (n int)
func (*ConfigEntry) String ¶
func (this *ConfigEntry) String() string
func (*ConfigEntry) Unmarshal ¶
func (m *ConfigEntry) Unmarshal(dAtA []byte) error
func (*ConfigEntry) VerboseEqual ¶
func (this *ConfigEntry) VerboseEqual(that interface{}) error
func (*ConfigEntry) XXX_DiscardUnknown ¶
func (m *ConfigEntry) XXX_DiscardUnknown()
func (*ConfigEntry) XXX_Marshal ¶
func (m *ConfigEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigEntry) XXX_Merge ¶
func (m *ConfigEntry) XXX_Merge(src proto.Message)
func (*ConfigEntry) XXX_Size ¶
func (m *ConfigEntry) XXX_Size() int
func (*ConfigEntry) XXX_Unmarshal ¶
func (m *ConfigEntry) XXX_Unmarshal(b []byte) error
type CoreEvent ¶
type CoreEvent struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Actor *Actor `protobuf:"bytes,2,opt,name=actor,proto3" json:"actor,omitempty"` Process *Process `protobuf:"bytes,3,opt,name=process,proto3" json:"process,omitempty"` ProcessOldStatus Process_Status `protobuf:"varint,4,opt,name=processOldStatus,proto3,enum=xbus.Process_Status" json:"processOldStatus,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedCoreEvent ¶
func (*CoreEvent) Descriptor ¶
func (*CoreEvent) GetProcess ¶
func (*CoreEvent) GetProcessOldStatus ¶
func (m *CoreEvent) GetProcessOldStatus() Process_Status
func (*CoreEvent) MarshalToSizedBuffer ¶
func (*CoreEvent) ProtoMessage ¶
func (*CoreEvent) ProtoMessage()
func (*CoreEvent) VerboseEqual ¶
func (*CoreEvent) XXX_DiscardUnknown ¶
func (m *CoreEvent) XXX_DiscardUnknown()
func (*CoreEvent) XXX_Marshal ¶
func (*CoreEvent) XXX_Unmarshal ¶
type CoreEventsActorSubscription ¶
type CoreEventsActorSubscription struct { *nats.Subscription // contains filtered or unexported fields }
type CoreEventsClient ¶
type CoreEventsClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewCoreEventsClient ¶
func NewCoreEventsClient(nc nrpc.NatsConn) *CoreEventsClient
func (*CoreEventsClient) ActorSubject ¶
func (c *CoreEventsClient) ActorSubject() string
func (*CoreEventsClient) ActorSubscribe ¶
func (c *CoreEventsClient) ActorSubscribe( handler func(CoreEvent), ) (sub *nats.Subscription, err error)
func (*CoreEventsClient) ActorSubscribeChan ¶
func (c *CoreEventsClient) ActorSubscribeChan() (<-chan CoreEvent, *nats.Subscription, error)
func (*CoreEventsClient) ActorSubscribeSync ¶
func (c *CoreEventsClient) ActorSubscribeSync() (sub *CoreEventsActorSubscription, err error)
func (*CoreEventsClient) EnvelopeSubject ¶
func (c *CoreEventsClient) EnvelopeSubject() string
func (*CoreEventsClient) EnvelopeSubscribe ¶
func (c *CoreEventsClient) EnvelopeSubscribe( handler func(EnvelopeEvent), ) (sub *nats.Subscription, err error)
func (*CoreEventsClient) EnvelopeSubscribeChan ¶
func (c *CoreEventsClient) EnvelopeSubscribeChan() (<-chan EnvelopeEvent, *nats.Subscription, error)
func (*CoreEventsClient) EnvelopeSubscribeSync ¶
func (c *CoreEventsClient) EnvelopeSubscribeSync() (sub *CoreEventsEnvelopeSubscription, err error)
func (*CoreEventsClient) ProcessNodeReadySubject ¶
func (c *CoreEventsClient) ProcessNodeReadySubject() string
func (*CoreEventsClient) ProcessNodeReadySubscribe ¶
func (c *CoreEventsClient) ProcessNodeReadySubscribe( handler func(ProcessNodeReadyEvent), ) (sub *nats.Subscription, err error)
func (*CoreEventsClient) ProcessNodeReadySubscribeChan ¶
func (c *CoreEventsClient) ProcessNodeReadySubscribeChan() (<-chan ProcessNodeReadyEvent, *nats.Subscription, error)
func (*CoreEventsClient) ProcessNodeReadySubscribeSync ¶
func (c *CoreEventsClient) ProcessNodeReadySubscribeSync() (sub *CoreEventsProcessNodeReadySubscription, err error)
func (*CoreEventsClient) ProcessSubject ¶
func (c *CoreEventsClient) ProcessSubject() string
func (*CoreEventsClient) ProcessSubscribe ¶
func (c *CoreEventsClient) ProcessSubscribe( handler func(CoreEvent), ) (sub *nats.Subscription, err error)
func (*CoreEventsClient) ProcessSubscribeChan ¶
func (c *CoreEventsClient) ProcessSubscribeChan() (<-chan CoreEvent, *nats.Subscription, error)
func (*CoreEventsClient) ProcessSubscribeSync ¶
func (c *CoreEventsClient) ProcessSubscribeSync() (sub *CoreEventsProcessSubscription, err error)
type CoreEventsEnvelopeSubscription ¶
type CoreEventsEnvelopeSubscription struct { *nats.Subscription // contains filtered or unexported fields }
func (*CoreEventsEnvelopeSubscription) Next ¶
func (s *CoreEventsEnvelopeSubscription) Next(timeout time.Duration) (next EnvelopeEvent, err error)
type CoreEventsHandler ¶
type CoreEventsHandler struct {
// contains filtered or unexported fields
}
CoreEventsHandler provides a NATS subscription handler that can serve a subscription using a given CoreEventsServer implementation.
func NewCoreEventsConcurrentHandler ¶
func NewCoreEventsConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s CoreEventsServer) *CoreEventsHandler
func NewCoreEventsHandler ¶
func NewCoreEventsHandler(ctx context.Context, nc nrpc.NatsConn, s CoreEventsServer) *CoreEventsHandler
func (*CoreEventsHandler) ActorPublish ¶
func (h *CoreEventsHandler) ActorPublish(msg CoreEvent) error
func (*CoreEventsHandler) EnvelopePublish ¶
func (h *CoreEventsHandler) EnvelopePublish(msg EnvelopeEvent) error
func (*CoreEventsHandler) ProcessNodeReadyPublish ¶
func (h *CoreEventsHandler) ProcessNodeReadyPublish(msg ProcessNodeReadyEvent) error
func (*CoreEventsHandler) ProcessPublish ¶
func (h *CoreEventsHandler) ProcessPublish(msg CoreEvent) error
func (*CoreEventsHandler) SetEncodings ¶
func (h *CoreEventsHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*CoreEventsHandler) Subject ¶
func (h *CoreEventsHandler) Subject() string
type CoreEventsProcessNodeReadySubscription ¶
type CoreEventsProcessNodeReadySubscription struct { *nats.Subscription // contains filtered or unexported fields }
func (*CoreEventsProcessNodeReadySubscription) Next ¶
func (s *CoreEventsProcessNodeReadySubscription) Next(timeout time.Duration) (next ProcessNodeReadyEvent, err error)
type CoreEventsProcessSubscription ¶
type CoreEventsProcessSubscription struct { *nats.Subscription // contains filtered or unexported fields }
type CoreEventsServer ¶
type CoreEventsServer interface { }
CoreEventsServer is the interface that providers of the service CoreEvents should implement.
type DirectorClient ¶
type DirectorClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewDirectorClient ¶
func NewDirectorClient(nc nrpc.NatsConn) *DirectorClient
func (*DirectorClient) GetRunningActorRequestList ¶
func (c *DirectorClient) GetRunningActorRequestList( ctx context.Context, actorID string, cb func(context.Context, ActorProcessRequest), ) error
func (*DirectorClient) Log ¶
func (c *DirectorClient) Log(actorID string, req ActorLogRequest) (err error)
func (*DirectorClient) ProcessingEnd ¶
func (c *DirectorClient) ProcessingEnd(actorID string, req ActorProcessingState) (err error)
type DirectorHandler ¶
type DirectorHandler struct {
// contains filtered or unexported fields
}
DirectorHandler provides a NATS subscription handler that can serve a subscription using a given DirectorServer implementation.
func NewDirectorConcurrentHandler ¶
func NewDirectorConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s DirectorServer) *DirectorHandler
func NewDirectorHandler ¶
func NewDirectorHandler(ctx context.Context, nc nrpc.NatsConn, s DirectorServer) *DirectorHandler
func (*DirectorHandler) Handler ¶
func (h *DirectorHandler) Handler(msg *nats.Msg)
func (*DirectorHandler) SetEncodings ¶
func (h *DirectorHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*DirectorHandler) Subject ¶
func (h *DirectorHandler) Subject() string
type DirectorServer ¶
type DirectorServer interface { ProcessingEnd(ctx context.Context, actorID string, req ActorProcessingState) (err error) Log(ctx context.Context, actorID string, req ActorLogRequest) (err error) GetRunningActorRequestList(ctx context.Context, actorID string, pushRep func(ActorProcessRequest)) (err error) }
DirectorServer is the interface that providers of the service Director should implement.
type EmitterEnvelopeState ¶
type EmitterEnvelopeState struct { ProcessID UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=UUID" json:"processID"` ProcessCreatedAt *time.Time `protobuf:"bytes,6,opt,name=processCreatedAt,proto3,stdtime" json:"processCreatedAt,omitempty"` Status Process_Status `protobuf:"varint,2,opt,name=status,proto3,enum=xbus.Process_Status" json:"status,omitempty"` Errors []LogMessage `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors"` Response *EnvelopeFragmentAndPosition `protobuf:"bytes,4,opt,name=response,proto3" json:"response,omitempty"` TriggerEnvelope *EnvelopeFragmentAndPosition `protobuf:"bytes,5,opt,name=triggerEnvelope,proto3" json:"triggerEnvelope,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEmitterEnvelopeState ¶
func NewPopulatedEmitterEnvelopeState(r randyXbus, easy bool) *EmitterEnvelopeState
func (*EmitterEnvelopeState) Descriptor ¶
func (*EmitterEnvelopeState) Descriptor() ([]byte, []int)
func (*EmitterEnvelopeState) Equal ¶
func (this *EmitterEnvelopeState) Equal(that interface{}) bool
func (*EmitterEnvelopeState) GetErrors ¶
func (m *EmitterEnvelopeState) GetErrors() []LogMessage
func (*EmitterEnvelopeState) GetProcessCreatedAt ¶
func (m *EmitterEnvelopeState) GetProcessCreatedAt() *time.Time
func (*EmitterEnvelopeState) GetResponse ¶
func (m *EmitterEnvelopeState) GetResponse() *EnvelopeFragmentAndPosition
func (*EmitterEnvelopeState) GetStatus ¶
func (m *EmitterEnvelopeState) GetStatus() Process_Status
func (*EmitterEnvelopeState) GetTriggerEnvelope ¶
func (m *EmitterEnvelopeState) GetTriggerEnvelope() *EnvelopeFragmentAndPosition
func (*EmitterEnvelopeState) GoString ¶
func (this *EmitterEnvelopeState) GoString() string
func (*EmitterEnvelopeState) Marshal ¶
func (m *EmitterEnvelopeState) Marshal() (dAtA []byte, err error)
func (*EmitterEnvelopeState) MarshalTo ¶
func (m *EmitterEnvelopeState) MarshalTo(dAtA []byte) (int, error)
func (*EmitterEnvelopeState) MarshalToSizedBuffer ¶
func (m *EmitterEnvelopeState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmitterEnvelopeState) ProtoMessage ¶
func (*EmitterEnvelopeState) ProtoMessage()
func (*EmitterEnvelopeState) Reset ¶
func (m *EmitterEnvelopeState) Reset()
func (*EmitterEnvelopeState) Size ¶
func (m *EmitterEnvelopeState) Size() (n int)
func (*EmitterEnvelopeState) String ¶
func (this *EmitterEnvelopeState) String() string
func (*EmitterEnvelopeState) Unmarshal ¶
func (m *EmitterEnvelopeState) Unmarshal(dAtA []byte) error
func (*EmitterEnvelopeState) VerboseEqual ¶
func (this *EmitterEnvelopeState) VerboseEqual(that interface{}) error
func (*EmitterEnvelopeState) XXX_DiscardUnknown ¶
func (m *EmitterEnvelopeState) XXX_DiscardUnknown()
func (*EmitterEnvelopeState) XXX_Marshal ¶
func (m *EmitterEnvelopeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmitterEnvelopeState) XXX_Merge ¶
func (m *EmitterEnvelopeState) XXX_Merge(src proto.Message)
func (*EmitterEnvelopeState) XXX_Size ¶
func (m *EmitterEnvelopeState) XXX_Size() int
func (*EmitterEnvelopeState) XXX_Unmarshal ¶
func (m *EmitterEnvelopeState) XXX_Unmarshal(b []byte) error
type EmitterEnvelopeStateList ¶
type EmitterEnvelopeStateList struct { List []*EmitterEnvelopeState `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEmitterEnvelopeStateList ¶
func NewPopulatedEmitterEnvelopeStateList(r randyXbus, easy bool) *EmitterEnvelopeStateList
func (*EmitterEnvelopeStateList) Descriptor ¶
func (*EmitterEnvelopeStateList) Descriptor() ([]byte, []int)
func (*EmitterEnvelopeStateList) Equal ¶
func (this *EmitterEnvelopeStateList) Equal(that interface{}) bool
func (*EmitterEnvelopeStateList) GetList ¶
func (m *EmitterEnvelopeStateList) GetList() []*EmitterEnvelopeState
func (*EmitterEnvelopeStateList) GoString ¶
func (this *EmitterEnvelopeStateList) GoString() string
func (*EmitterEnvelopeStateList) Marshal ¶
func (m *EmitterEnvelopeStateList) Marshal() (dAtA []byte, err error)
func (*EmitterEnvelopeStateList) MarshalTo ¶
func (m *EmitterEnvelopeStateList) MarshalTo(dAtA []byte) (int, error)
func (*EmitterEnvelopeStateList) MarshalToSizedBuffer ¶
func (m *EmitterEnvelopeStateList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmitterEnvelopeStateList) ProtoMessage ¶
func (*EmitterEnvelopeStateList) ProtoMessage()
func (*EmitterEnvelopeStateList) Reset ¶
func (m *EmitterEnvelopeStateList) Reset()
func (*EmitterEnvelopeStateList) Size ¶
func (m *EmitterEnvelopeStateList) Size() (n int)
func (*EmitterEnvelopeStateList) String ¶
func (this *EmitterEnvelopeStateList) String() string
func (*EmitterEnvelopeStateList) Unmarshal ¶
func (m *EmitterEnvelopeStateList) Unmarshal(dAtA []byte) error
func (*EmitterEnvelopeStateList) VerboseEqual ¶
func (this *EmitterEnvelopeStateList) VerboseEqual(that interface{}) error
func (*EmitterEnvelopeStateList) XXX_DiscardUnknown ¶
func (m *EmitterEnvelopeStateList) XXX_DiscardUnknown()
func (*EmitterEnvelopeStateList) XXX_Marshal ¶
func (m *EmitterEnvelopeStateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmitterEnvelopeStateList) XXX_Merge ¶
func (m *EmitterEnvelopeStateList) XXX_Merge(src proto.Message)
func (*EmitterEnvelopeStateList) XXX_Size ¶
func (m *EmitterEnvelopeStateList) XXX_Size() int
func (*EmitterEnvelopeStateList) XXX_Unmarshal ¶
func (m *EmitterEnvelopeStateList) XXX_Unmarshal(b []byte) error
type Envelope ¶
type Envelope struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` EventIDs []UUID `protobuf:"bytes,3,rep,name=eventIDs,proto3,customtype=UUID" json:"eventIDs"` Events []Event `protobuf:"bytes,4,rep,name=events,proto3" json:"events"` Last bool `protobuf:"varint,5,opt,name=last,proto3" json:"last,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEnvelope ¶
func (*Envelope) Descriptor ¶
func (*Envelope) MarshalToSizedBuffer ¶
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
func (*Envelope) VerboseEqual ¶
func (*Envelope) XXX_DiscardUnknown ¶
func (m *Envelope) XXX_DiscardUnknown()
func (*Envelope) XXX_Marshal ¶
func (*Envelope) XXX_Unmarshal ¶
type EnvelopeAck ¶
type EnvelopeAck struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` Status EnvelopeAck_ReceptionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=xbus.EnvelopeAck_ReceptionStatus" json:"status,omitempty"` Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewEnvelopeAck ¶
func NewEnvelopeAck(id UUID, status EnvelopeAck_ReceptionStatus) *EnvelopeAck
NewEnvelopeAck creates a normal EnvelopeAck
func NewEnvelopeAckError ¶
func NewEnvelopeAckError(id UUID, err error) *EnvelopeAck
NewEnvelopeAckError prepare a EnvelopeAck from an error
func NewPopulatedEnvelopeAck ¶
func NewPopulatedEnvelopeAck(r randyXbus, easy bool) *EnvelopeAck
func (*EnvelopeAck) Descriptor ¶
func (*EnvelopeAck) Descriptor() ([]byte, []int)
func (*EnvelopeAck) Equal ¶
func (this *EnvelopeAck) Equal(that interface{}) bool
func (*EnvelopeAck) GetReason ¶
func (m *EnvelopeAck) GetReason() string
func (*EnvelopeAck) GetStatus ¶
func (m *EnvelopeAck) GetStatus() EnvelopeAck_ReceptionStatus
func (*EnvelopeAck) GoString ¶
func (this *EnvelopeAck) GoString() string
func (*EnvelopeAck) Marshal ¶
func (m *EnvelopeAck) Marshal() (dAtA []byte, err error)
func (*EnvelopeAck) MarshalToSizedBuffer ¶
func (m *EnvelopeAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EnvelopeAck) ProtoMessage ¶
func (*EnvelopeAck) ProtoMessage()
func (*EnvelopeAck) Reset ¶
func (m *EnvelopeAck) Reset()
func (*EnvelopeAck) Size ¶
func (m *EnvelopeAck) Size() (n int)
func (*EnvelopeAck) String ¶
func (this *EnvelopeAck) String() string
func (*EnvelopeAck) Unmarshal ¶
func (m *EnvelopeAck) Unmarshal(dAtA []byte) error
func (*EnvelopeAck) VerboseEqual ¶
func (this *EnvelopeAck) VerboseEqual(that interface{}) error
func (*EnvelopeAck) XXX_DiscardUnknown ¶
func (m *EnvelopeAck) XXX_DiscardUnknown()
func (*EnvelopeAck) XXX_Marshal ¶
func (m *EnvelopeAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvelopeAck) XXX_Merge ¶
func (m *EnvelopeAck) XXX_Merge(src proto.Message)
func (*EnvelopeAck) XXX_Size ¶
func (m *EnvelopeAck) XXX_Size() int
func (*EnvelopeAck) XXX_Unmarshal ¶
func (m *EnvelopeAck) XXX_Unmarshal(b []byte) error
type EnvelopeAck_ReceptionStatus ¶
type EnvelopeAck_ReceptionStatus int32
const ( EnvelopeAck_NOSTATUS EnvelopeAck_ReceptionStatus = 0 EnvelopeAck_RECEIVING EnvelopeAck_ReceptionStatus = 1 EnvelopeAck_ACCEPTED EnvelopeAck_ReceptionStatus = 2 EnvelopeAck_ERROR EnvelopeAck_ReceptionStatus = 3 )
func (EnvelopeAck_ReceptionStatus) EnumDescriptor ¶
func (EnvelopeAck_ReceptionStatus) EnumDescriptor() ([]byte, []int)
func (EnvelopeAck_ReceptionStatus) String ¶
func (x EnvelopeAck_ReceptionStatus) String() string
type EnvelopeEvent ¶
type EnvelopeEvent struct { EnvelopeID UUID `protobuf:"bytes,1,opt,name=envelopeID,proto3,customtype=UUID" json:"envelopeID"` Status EnvelopeEvent_Status `protobuf:"varint,2,opt,name=status,proto3,enum=xbus.EnvelopeEvent_Status" json:"status,omitempty"` NewData bool `protobuf:"varint,3,opt,name=newData,proto3" json:"newData,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEnvelopeEvent ¶
func NewPopulatedEnvelopeEvent(r randyXbus, easy bool) *EnvelopeEvent
func (*EnvelopeEvent) Descriptor ¶
func (*EnvelopeEvent) Descriptor() ([]byte, []int)
func (*EnvelopeEvent) Equal ¶
func (this *EnvelopeEvent) Equal(that interface{}) bool
func (*EnvelopeEvent) GetNewData ¶
func (m *EnvelopeEvent) GetNewData() bool
func (*EnvelopeEvent) GetStatus ¶
func (m *EnvelopeEvent) GetStatus() EnvelopeEvent_Status
func (*EnvelopeEvent) GoString ¶
func (this *EnvelopeEvent) GoString() string
func (*EnvelopeEvent) Marshal ¶
func (m *EnvelopeEvent) Marshal() (dAtA []byte, err error)
func (*EnvelopeEvent) MarshalToSizedBuffer ¶
func (m *EnvelopeEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EnvelopeEvent) ProtoMessage ¶
func (*EnvelopeEvent) ProtoMessage()
func (*EnvelopeEvent) Reset ¶
func (m *EnvelopeEvent) Reset()
func (*EnvelopeEvent) Size ¶
func (m *EnvelopeEvent) Size() (n int)
func (*EnvelopeEvent) String ¶
func (this *EnvelopeEvent) String() string
func (*EnvelopeEvent) Unmarshal ¶
func (m *EnvelopeEvent) Unmarshal(dAtA []byte) error
func (*EnvelopeEvent) VerboseEqual ¶
func (this *EnvelopeEvent) VerboseEqual(that interface{}) error
func (*EnvelopeEvent) XXX_DiscardUnknown ¶
func (m *EnvelopeEvent) XXX_DiscardUnknown()
func (*EnvelopeEvent) XXX_Marshal ¶
func (m *EnvelopeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvelopeEvent) XXX_Merge ¶
func (m *EnvelopeEvent) XXX_Merge(src proto.Message)
func (*EnvelopeEvent) XXX_Size ¶
func (m *EnvelopeEvent) XXX_Size() int
func (*EnvelopeEvent) XXX_Unmarshal ¶
func (m *EnvelopeEvent) XXX_Unmarshal(b []byte) error
type EnvelopeEvent_Status ¶
type EnvelopeEvent_Status int32
const ( EnvelopeEvent_UNKNOWN EnvelopeEvent_Status = 0 EnvelopeEvent_RECEIVING EnvelopeEvent_Status = 1 EnvelopeEvent_COMPLETE EnvelopeEvent_Status = 3 EnvelopeEvent_ERROR EnvelopeEvent_Status = 4 EnvelopeEvent_STALLED EnvelopeEvent_Status = 5 )
func (EnvelopeEvent_Status) EnumDescriptor ¶
func (EnvelopeEvent_Status) EnumDescriptor() ([]byte, []int)
func (EnvelopeEvent_Status) String ¶
func (x EnvelopeEvent_Status) String() string
type EnvelopeFragmentAndPosition ¶
type EnvelopeFragmentAndPosition struct { Fragment *Envelope `protobuf:"bytes,1,opt,name=fragment,proto3" json:"fragment,omitempty"` Position *EnvelopePosition `protobuf:"bytes,2,opt,name=position,proto3" json:"position,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEnvelopeFragmentAndPosition ¶
func NewPopulatedEnvelopeFragmentAndPosition(r randyXbus, easy bool) *EnvelopeFragmentAndPosition
func (*EnvelopeFragmentAndPosition) Descriptor ¶
func (*EnvelopeFragmentAndPosition) Descriptor() ([]byte, []int)
func (*EnvelopeFragmentAndPosition) Equal ¶
func (this *EnvelopeFragmentAndPosition) Equal(that interface{}) bool
func (*EnvelopeFragmentAndPosition) GetFragment ¶
func (m *EnvelopeFragmentAndPosition) GetFragment() *Envelope
func (*EnvelopeFragmentAndPosition) GetPosition ¶
func (m *EnvelopeFragmentAndPosition) GetPosition() *EnvelopePosition
func (*EnvelopeFragmentAndPosition) GoString ¶
func (this *EnvelopeFragmentAndPosition) GoString() string
func (*EnvelopeFragmentAndPosition) Marshal ¶
func (m *EnvelopeFragmentAndPosition) Marshal() (dAtA []byte, err error)
func (*EnvelopeFragmentAndPosition) MarshalTo ¶
func (m *EnvelopeFragmentAndPosition) MarshalTo(dAtA []byte) (int, error)
func (*EnvelopeFragmentAndPosition) MarshalToSizedBuffer ¶
func (m *EnvelopeFragmentAndPosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EnvelopeFragmentAndPosition) ProtoMessage ¶
func (*EnvelopeFragmentAndPosition) ProtoMessage()
func (*EnvelopeFragmentAndPosition) Reset ¶
func (m *EnvelopeFragmentAndPosition) Reset()
func (*EnvelopeFragmentAndPosition) Size ¶
func (m *EnvelopeFragmentAndPosition) Size() (n int)
func (*EnvelopeFragmentAndPosition) String ¶
func (this *EnvelopeFragmentAndPosition) String() string
func (*EnvelopeFragmentAndPosition) Unmarshal ¶
func (m *EnvelopeFragmentAndPosition) Unmarshal(dAtA []byte) error
func (*EnvelopeFragmentAndPosition) VerboseEqual ¶
func (this *EnvelopeFragmentAndPosition) VerboseEqual(that interface{}) error
func (*EnvelopeFragmentAndPosition) XXX_DiscardUnknown ¶
func (m *EnvelopeFragmentAndPosition) XXX_DiscardUnknown()
func (*EnvelopeFragmentAndPosition) XXX_Marshal ¶
func (m *EnvelopeFragmentAndPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvelopeFragmentAndPosition) XXX_Merge ¶
func (m *EnvelopeFragmentAndPosition) XXX_Merge(src proto.Message)
func (*EnvelopeFragmentAndPosition) XXX_Size ¶
func (m *EnvelopeFragmentAndPosition) XXX_Size() int
func (*EnvelopeFragmentAndPosition) XXX_Unmarshal ¶
func (m *EnvelopeFragmentAndPosition) XXX_Unmarshal(b []byte) error
type EnvelopePosition ¶
type EnvelopePosition struct { EnvelopeID UUID `protobuf:"bytes,1,opt,name=envelope_id,json=envelopeId,proto3,customtype=UUID" json:"envelope_id"` Start bool `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"` Complete bool `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"` EventPositions []*EventPosition `protobuf:"bytes,4,rep,name=eventPositions,proto3" json:"eventPositions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func EnvelopePositionStart ¶
func EnvelopePositionStart(id UUID) EnvelopePosition
EnvelopePositionStart returns the start position of an envelope
func NewPopulatedEnvelopePosition ¶
func NewPopulatedEnvelopePosition(r randyXbus, easy bool) *EnvelopePosition
func (*EnvelopePosition) Descriptor ¶
func (*EnvelopePosition) Descriptor() ([]byte, []int)
func (*EnvelopePosition) Equal ¶
func (this *EnvelopePosition) Equal(that interface{}) bool
func (*EnvelopePosition) GetComplete ¶
func (m *EnvelopePosition) GetComplete() bool
func (*EnvelopePosition) GetEventPositions ¶
func (m *EnvelopePosition) GetEventPositions() []*EventPosition
func (*EnvelopePosition) GetStart ¶
func (m *EnvelopePosition) GetStart() bool
func (*EnvelopePosition) GoString ¶
func (this *EnvelopePosition) GoString() string
func (*EnvelopePosition) Marshal ¶
func (m *EnvelopePosition) Marshal() (dAtA []byte, err error)
func (*EnvelopePosition) MarshalToSizedBuffer ¶
func (m *EnvelopePosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EnvelopePosition) ProtoMessage ¶
func (*EnvelopePosition) ProtoMessage()
func (*EnvelopePosition) Reset ¶
func (m *EnvelopePosition) Reset()
func (*EnvelopePosition) Size ¶
func (m *EnvelopePosition) Size() (n int)
func (*EnvelopePosition) String ¶
func (this *EnvelopePosition) String() string
func (*EnvelopePosition) Unmarshal ¶
func (m *EnvelopePosition) Unmarshal(dAtA []byte) error
func (*EnvelopePosition) VerboseEqual ¶
func (this *EnvelopePosition) VerboseEqual(that interface{}) error
func (*EnvelopePosition) XXX_DiscardUnknown ¶
func (m *EnvelopePosition) XXX_DiscardUnknown()
func (*EnvelopePosition) XXX_Marshal ¶
func (m *EnvelopePosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvelopePosition) XXX_Merge ¶
func (m *EnvelopePosition) XXX_Merge(src proto.Message)
func (*EnvelopePosition) XXX_Size ¶
func (m *EnvelopePosition) XXX_Size() int
func (*EnvelopePosition) XXX_Unmarshal ¶
func (m *EnvelopePosition) XXX_Unmarshal(b []byte) error
type EnvelopeStorageClient ¶
type EnvelopeStorageClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewEnvelopeStorageClient ¶
func NewEnvelopeStorageClient(nc nrpc.NatsConn) *EnvelopeStorageClient
func (*EnvelopeStorageClient) Retrieve ¶
func (c *EnvelopeStorageClient) Retrieve( ctx context.Context, clientKind string, clientID string, req EnvelopePosition, cb func(context.Context, EnvelopeFragmentAndPosition), ) error
type EnvelopeStorageHandler ¶
type EnvelopeStorageHandler struct {
// contains filtered or unexported fields
}
EnvelopeStorageHandler provides a NATS subscription handler that can serve a subscription using a given EnvelopeStorageServer implementation.
func NewEnvelopeStorageConcurrentHandler ¶
func NewEnvelopeStorageConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s EnvelopeStorageServer) *EnvelopeStorageHandler
func NewEnvelopeStorageHandler ¶
func NewEnvelopeStorageHandler(ctx context.Context, nc nrpc.NatsConn, s EnvelopeStorageServer) *EnvelopeStorageHandler
func (*EnvelopeStorageHandler) Handler ¶
func (h *EnvelopeStorageHandler) Handler(msg *nats.Msg)
func (*EnvelopeStorageHandler) SetEncodings ¶
func (h *EnvelopeStorageHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*EnvelopeStorageHandler) Subject ¶
func (h *EnvelopeStorageHandler) Subject() string
type EnvelopeStorageServer ¶
type EnvelopeStorageServer interface {
Retrieve(ctx context.Context, clientKind string, clientID string, req EnvelopePosition, pushRep func(EnvelopeFragmentAndPosition)) (err error)
}
EnvelopeStorageServer is the interface that providers of the service EnvelopeStorage should implement.
type EnvelopeTarget ¶
type EnvelopeTarget struct { ActorID UUID `protobuf:"bytes,1,opt,name=actorID,proto3,customtype=UUID" json:"actorID"` NodeID string `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Input string `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEnvelopeTarget ¶
func NewPopulatedEnvelopeTarget(r randyXbus, easy bool) *EnvelopeTarget
func (*EnvelopeTarget) Descriptor ¶
func (*EnvelopeTarget) Descriptor() ([]byte, []int)
func (*EnvelopeTarget) Equal ¶
func (this *EnvelopeTarget) Equal(that interface{}) bool
func (*EnvelopeTarget) GetInput ¶
func (m *EnvelopeTarget) GetInput() string
func (*EnvelopeTarget) GetNodeID ¶
func (m *EnvelopeTarget) GetNodeID() string
func (*EnvelopeTarget) GoString ¶
func (this *EnvelopeTarget) GoString() string
func (*EnvelopeTarget) Marshal ¶
func (m *EnvelopeTarget) Marshal() (dAtA []byte, err error)
func (*EnvelopeTarget) MarshalToSizedBuffer ¶
func (m *EnvelopeTarget) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EnvelopeTarget) ProtoMessage ¶
func (*EnvelopeTarget) ProtoMessage()
func (*EnvelopeTarget) Reset ¶
func (m *EnvelopeTarget) Reset()
func (*EnvelopeTarget) Size ¶
func (m *EnvelopeTarget) Size() (n int)
func (*EnvelopeTarget) String ¶
func (this *EnvelopeTarget) String() string
func (*EnvelopeTarget) Unmarshal ¶
func (m *EnvelopeTarget) Unmarshal(dAtA []byte) error
func (*EnvelopeTarget) VerboseEqual ¶
func (this *EnvelopeTarget) VerboseEqual(that interface{}) error
func (*EnvelopeTarget) XXX_DiscardUnknown ¶
func (m *EnvelopeTarget) XXX_DiscardUnknown()
func (*EnvelopeTarget) XXX_Marshal ¶
func (m *EnvelopeTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvelopeTarget) XXX_Merge ¶
func (m *EnvelopeTarget) XXX_Merge(src proto.Message)
func (*EnvelopeTarget) XXX_Size ¶
func (m *EnvelopeTarget) XXX_Size() int
func (*EnvelopeTarget) XXX_Unmarshal ¶
func (m *EnvelopeTarget) XXX_Unmarshal(b []byte) error
type Event ¶
type Event struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` ItemCount uint64 `protobuf:"varint,4,opt,name=itemCount,proto3" json:"itemCount,omitempty"` /// A Castagnoli CRC32 checksum calculated on the concatenation of: // // * the event id binary representation // * the event type // * all the items Checksum Checksum `protobuf:"varint,5,opt,name=checksum,proto3,casttype=Checksum" json:"checksum,omitempty"` Items []Item `protobuf:"bytes,6,rep,name=items,proto3,casttype=Item" json:"items,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* A message inside an envelope
.. hint::
Do not be confused by the name "Event", it really is a *message*. The name may change in a future version of the API
func NewPopulatedEvent ¶
func (*Event) Descriptor ¶
func (*Event) GetChecksum ¶
func (*Event) GetItemCount ¶
func (Event) MarshalJSONPB ¶
MarshalJSONPB encode a Event with an additional "encoding" that is the actual encoding of the items
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) UnmarshalJSON ¶
UnmarshalJSON decodes the items depending on the declared encoding
func (*Event) UnmarshalJSONPB ¶
func (event *Event) UnmarshalJSONPB(u *jsonpb.Unmarshaler, data []byte) error
UnmarshalJSONPB ...
func (*Event) VerboseEqual ¶
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventPosition ¶
type EventPosition struct { EventID UUID `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3,customtype=UUID" json:"event_id"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` ItemCount uint64 `protobuf:"varint,3,opt,name=itemCount,proto3" json:"itemCount,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedEventPosition ¶
func NewPopulatedEventPosition(r randyXbus, easy bool) *EventPosition
func (*EventPosition) Descriptor ¶
func (*EventPosition) Descriptor() ([]byte, []int)
func (*EventPosition) Equal ¶
func (this *EventPosition) Equal(that interface{}) bool
func (*EventPosition) GetIndex ¶
func (m *EventPosition) GetIndex() uint64
func (*EventPosition) GetItemCount ¶
func (m *EventPosition) GetItemCount() uint64
func (*EventPosition) GoString ¶
func (this *EventPosition) GoString() string
func (*EventPosition) Marshal ¶
func (m *EventPosition) Marshal() (dAtA []byte, err error)
func (*EventPosition) MarshalToSizedBuffer ¶
func (m *EventPosition) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventPosition) ProtoMessage ¶
func (*EventPosition) ProtoMessage()
func (*EventPosition) Reset ¶
func (m *EventPosition) Reset()
func (*EventPosition) Size ¶
func (m *EventPosition) Size() (n int)
func (*EventPosition) String ¶
func (this *EventPosition) String() string
func (*EventPosition) Unmarshal ¶
func (m *EventPosition) Unmarshal(dAtA []byte) error
func (*EventPosition) VerboseEqual ¶
func (this *EventPosition) VerboseEqual(that interface{}) error
func (*EventPosition) XXX_DiscardUnknown ¶
func (m *EventPosition) XXX_DiscardUnknown()
func (*EventPosition) XXX_Marshal ¶
func (m *EventPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventPosition) XXX_Merge ¶
func (m *EventPosition) XXX_Merge(src proto.Message)
func (*EventPosition) XXX_Size ¶
func (m *EventPosition) XXX_Size() int
func (*EventPosition) XXX_Unmarshal ¶
func (m *EventPosition) XXX_Unmarshal(b []byte) error
type GetEnvelopeStateRequest ¶
type GetEnvelopeStateRequest struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedGetEnvelopeStateRequest ¶
func NewPopulatedGetEnvelopeStateRequest(r randyXbus, easy bool) *GetEnvelopeStateRequest
func (*GetEnvelopeStateRequest) Descriptor ¶
func (*GetEnvelopeStateRequest) Descriptor() ([]byte, []int)
func (*GetEnvelopeStateRequest) Equal ¶
func (this *GetEnvelopeStateRequest) Equal(that interface{}) bool
func (*GetEnvelopeStateRequest) GoString ¶
func (this *GetEnvelopeStateRequest) GoString() string
func (*GetEnvelopeStateRequest) Marshal ¶
func (m *GetEnvelopeStateRequest) Marshal() (dAtA []byte, err error)
func (*GetEnvelopeStateRequest) MarshalTo ¶
func (m *GetEnvelopeStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetEnvelopeStateRequest) MarshalToSizedBuffer ¶
func (m *GetEnvelopeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetEnvelopeStateRequest) ProtoMessage ¶
func (*GetEnvelopeStateRequest) ProtoMessage()
func (*GetEnvelopeStateRequest) Reset ¶
func (m *GetEnvelopeStateRequest) Reset()
func (*GetEnvelopeStateRequest) Size ¶
func (m *GetEnvelopeStateRequest) Size() (n int)
func (*GetEnvelopeStateRequest) String ¶
func (this *GetEnvelopeStateRequest) String() string
func (*GetEnvelopeStateRequest) Unmarshal ¶
func (m *GetEnvelopeStateRequest) Unmarshal(dAtA []byte) error
func (*GetEnvelopeStateRequest) VerboseEqual ¶
func (this *GetEnvelopeStateRequest) VerboseEqual(that interface{}) error
func (*GetEnvelopeStateRequest) XXX_DiscardUnknown ¶
func (m *GetEnvelopeStateRequest) XXX_DiscardUnknown()
func (*GetEnvelopeStateRequest) XXX_Marshal ¶
func (m *GetEnvelopeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetEnvelopeStateRequest) XXX_Merge ¶
func (m *GetEnvelopeStateRequest) XXX_Merge(src proto.Message)
func (*GetEnvelopeStateRequest) XXX_Size ¶
func (m *GetEnvelopeStateRequest) XXX_Size() int
func (*GetEnvelopeStateRequest) XXX_Unmarshal ¶
func (m *GetEnvelopeStateRequest) XXX_Unmarshal(b []byte) error
type GetSessionTokenRequest ¶
type GetSessionTokenRequest struct { /// request the token to expire in a number of seconds ExpiresIn uint32 `protobuf:"varint,1,opt,name=expiresIn,proto3" json:"expiresIn,omitempty"` /// Invalidate a previous session token InvalidateToken string `protobuf:"bytes,2,opt,name=invalidateToken,proto3" json:"invalidateToken,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedGetSessionTokenRequest ¶
func NewPopulatedGetSessionTokenRequest(r randyXbus, easy bool) *GetSessionTokenRequest
func (*GetSessionTokenRequest) Descriptor ¶
func (*GetSessionTokenRequest) Descriptor() ([]byte, []int)
func (*GetSessionTokenRequest) Equal ¶
func (this *GetSessionTokenRequest) Equal(that interface{}) bool
func (*GetSessionTokenRequest) GetExpiresIn ¶
func (m *GetSessionTokenRequest) GetExpiresIn() uint32
func (*GetSessionTokenRequest) GetInvalidateToken ¶
func (m *GetSessionTokenRequest) GetInvalidateToken() string
func (*GetSessionTokenRequest) GoString ¶
func (this *GetSessionTokenRequest) GoString() string
func (*GetSessionTokenRequest) Marshal ¶
func (m *GetSessionTokenRequest) Marshal() (dAtA []byte, err error)
func (*GetSessionTokenRequest) MarshalTo ¶
func (m *GetSessionTokenRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetSessionTokenRequest) MarshalToSizedBuffer ¶
func (m *GetSessionTokenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetSessionTokenRequest) ProtoMessage ¶
func (*GetSessionTokenRequest) ProtoMessage()
func (*GetSessionTokenRequest) Reset ¶
func (m *GetSessionTokenRequest) Reset()
func (*GetSessionTokenRequest) Size ¶
func (m *GetSessionTokenRequest) Size() (n int)
func (*GetSessionTokenRequest) String ¶
func (this *GetSessionTokenRequest) String() string
func (*GetSessionTokenRequest) Unmarshal ¶
func (m *GetSessionTokenRequest) Unmarshal(dAtA []byte) error
func (*GetSessionTokenRequest) VerboseEqual ¶
func (this *GetSessionTokenRequest) VerboseEqual(that interface{}) error
func (*GetSessionTokenRequest) XXX_DiscardUnknown ¶
func (m *GetSessionTokenRequest) XXX_DiscardUnknown()
func (*GetSessionTokenRequest) XXX_Marshal ¶
func (m *GetSessionTokenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSessionTokenRequest) XXX_Merge ¶
func (m *GetSessionTokenRequest) XXX_Merge(src proto.Message)
func (*GetSessionTokenRequest) XXX_Size ¶
func (m *GetSessionTokenRequest) XXX_Size() int
func (*GetSessionTokenRequest) XXX_Unmarshal ¶
func (m *GetSessionTokenRequest) XXX_Unmarshal(b []byte) error
type Item ¶
type Item []byte
Item ...
func ChunksAsItems ¶
ChunksAsItems converts a slice of chunks into a slice of items
func JSONUnmarshalItem ¶
func JSONUnmarshalItem(encoding ItemEncoding, raw json.RawMessage) (Item, error)
JSONUnmarshalItem unmarshals a single item
func (Item) MarshalJSONEncoded ¶
func (item Item) MarshalJSONEncoded(encoding ItemEncoding) ([]byte, error)
MarshalJSONEncoded encodes a Item to JSON
func (Item) MarshalYAML ¶
MarshalYAML customizes YAML marshaling
type ItemEncoding ¶
type ItemEncoding int
ItemEncoding The idem encoding in a json payload
const ( // ItemBinary is for base64 encoded data ItemBinary ItemEncoding = iota // ItemText is for text encoded data ItemText // ItemJSON is for embedding json directly ItemJSON )
func ParseItemEncodingList ¶
func ParseItemEncodingList(s string) ([]ItemEncoding, error)
ParseItemEncodingList parses a comma separated list of item encodings Space characters are trimmed from each item
func (ItemEncoding) MarshalText ¶
func (i ItemEncoding) MarshalText() ([]byte, error)
func (ItemEncoding) String ¶
func (i ItemEncoding) String() string
func (*ItemEncoding) UnmarshalText ¶
func (i *ItemEncoding) UnmarshalText(text []byte) error
type JSONRawEvent ¶
type JSONRawEvent struct { ID UUID `json:"id"` Type string `json:"type,omitempty"` Index json.RawMessage `json:"index,omitempty"` ItemCount json.RawMessage `json:"itemCount,omitempty"` Checksum Checksum `json:"checksum,omitempty"` Items []json.RawMessage `json:"items,omitempty"` ItemEncoding ItemEncoding `json:"encoding"` }
JSONRawEvent is a Event with raw items It serves as a temporary decoding structure
type LogEntry ¶
type LogEntry struct { EnvelopeID UUID `protobuf:"bytes,1,opt,name=envelopeID,proto3,customtype=UUID" json:"envelopeID"` ActorID UUID `protobuf:"bytes,2,opt,name=actorID,proto3,customtype=UUID" json:"actorID"` ProcessID UUID `protobuf:"bytes,3,opt,name=processID,proto3,customtype=UUID" json:"processID"` NodeID string `protobuf:"bytes,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Message LogMessage `protobuf:"bytes,5,opt,name=message,proto3" json:"message"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedLogEntry ¶
func (*LogEntry) Descriptor ¶
func (*LogEntry) GetMessage ¶
func (m *LogEntry) GetMessage() LogMessage
func (*LogEntry) MarshalToSizedBuffer ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) VerboseEqual ¶
func (*LogEntry) XXX_DiscardUnknown ¶
func (m *LogEntry) XXX_DiscardUnknown()
func (*LogEntry) XXX_Marshal ¶
func (*LogEntry) XXX_Unmarshal ¶
type LogLevel ¶
type LogLevel int32
* Defines the severity of a log entry
func (LogLevel) EnumDescriptor ¶
func (LogLevel) MarshalText ¶
MarshalText serialize a LogLevel
func (*LogLevel) UnmarshalText ¶
UnmarshalText parses a LogLevel string
type LogMessage ¶
type LogMessage struct { // timestamp of the log entry Time time.Time `protobuf:"bytes,1,opt,name=time,proto3,stdtime" json:"time"` // severity level Level LogLevel `protobuf:"varint,2,opt,name=level,proto3,enum=xbus.LogLevel" json:"level,omitempty"` // entry text Text string `protobuf:"bytes,3,opt,name=Text,proto3" json:"Text,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* A logging entry
func NewPopulatedLogMessage ¶
func NewPopulatedLogMessage(r randyXbus, easy bool) *LogMessage
func (*LogMessage) Descriptor ¶
func (*LogMessage) Descriptor() ([]byte, []int)
func (*LogMessage) Equal ¶
func (this *LogMessage) Equal(that interface{}) bool
func (*LogMessage) GetLevel ¶
func (m *LogMessage) GetLevel() LogLevel
func (*LogMessage) GetText ¶
func (m *LogMessage) GetText() string
func (*LogMessage) GetTime ¶
func (m *LogMessage) GetTime() time.Time
func (*LogMessage) GoString ¶
func (this *LogMessage) GoString() string
func (*LogMessage) Marshal ¶
func (m *LogMessage) Marshal() (dAtA []byte, err error)
func (*LogMessage) MarshalToSizedBuffer ¶
func (m *LogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) Reset ¶
func (m *LogMessage) Reset()
func (*LogMessage) Size ¶
func (m *LogMessage) Size() (n int)
func (*LogMessage) String ¶
func (this *LogMessage) String() string
func (*LogMessage) Unmarshal ¶
func (m *LogMessage) Unmarshal(dAtA []byte) error
func (*LogMessage) VerboseEqual ¶
func (this *LogMessage) VerboseEqual(that interface{}) error
func (*LogMessage) XXX_DiscardUnknown ¶
func (m *LogMessage) XXX_DiscardUnknown()
func (*LogMessage) XXX_Marshal ¶
func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogMessage) XXX_Merge ¶
func (m *LogMessage) XXX_Merge(src proto.Message)
func (*LogMessage) XXX_Size ¶
func (m *LogMessage) XXX_Size() int
func (*LogMessage) XXX_Unmarshal ¶
func (m *LogMessage) XXX_Unmarshal(b []byte) error
type OutputRequest ¶
type OutputRequest struct { Context *ProcessingContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Output string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` Close bool `protobuf:"varint,3,opt,name=close,proto3" json:"close,omitempty"` Envelope *Envelope `protobuf:"bytes,4,opt,name=envelope,proto3" json:"envelope,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedOutputRequest ¶
func NewPopulatedOutputRequest(r randyXbus, easy bool) *OutputRequest
func (*OutputRequest) Descriptor ¶
func (*OutputRequest) Descriptor() ([]byte, []int)
func (*OutputRequest) Equal ¶
func (this *OutputRequest) Equal(that interface{}) bool
func (*OutputRequest) GetClose ¶
func (m *OutputRequest) GetClose() bool
func (*OutputRequest) GetContext ¶
func (m *OutputRequest) GetContext() *ProcessingContext
func (*OutputRequest) GetEnvelope ¶
func (m *OutputRequest) GetEnvelope() *Envelope
func (*OutputRequest) GetOutput ¶
func (m *OutputRequest) GetOutput() string
func (*OutputRequest) GoString ¶
func (this *OutputRequest) GoString() string
func (*OutputRequest) Marshal ¶
func (m *OutputRequest) Marshal() (dAtA []byte, err error)
func (*OutputRequest) MarshalToSizedBuffer ¶
func (m *OutputRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OutputRequest) ProtoMessage ¶
func (*OutputRequest) ProtoMessage()
func (*OutputRequest) Reset ¶
func (m *OutputRequest) Reset()
func (*OutputRequest) Size ¶
func (m *OutputRequest) Size() (n int)
func (*OutputRequest) String ¶
func (this *OutputRequest) String() string
func (*OutputRequest) Unmarshal ¶
func (m *OutputRequest) Unmarshal(dAtA []byte) error
func (*OutputRequest) VerboseEqual ¶
func (this *OutputRequest) VerboseEqual(that interface{}) error
func (*OutputRequest) XXX_DiscardUnknown ¶
func (m *OutputRequest) XXX_DiscardUnknown()
func (*OutputRequest) XXX_Marshal ¶
func (m *OutputRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputRequest) XXX_Merge ¶
func (m *OutputRequest) XXX_Merge(src proto.Message)
func (*OutputRequest) XXX_Size ¶
func (m *OutputRequest) XXX_Size() int
func (*OutputRequest) XXX_Unmarshal ¶
func (m *OutputRequest) XXX_Unmarshal(b []byte) error
type PMProcess ¶
type PMProcess struct { Process Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process"` Level LogLevel `protobuf:"varint,2,opt,name=level,proto3,enum=xbus.LogLevel" json:"level,omitempty"` Status PMProcess_Status `protobuf:"varint,3,opt,name=status,proto3,enum=xbus.PMProcess_Status" json:"status,omitempty"` Comment string `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"` Logs []LogEntry `protobuf:"bytes,5,rep,name=logs,proto3" json:"logs"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPMProcess ¶
func (*PMProcess) Descriptor ¶
func (*PMProcess) GetComment ¶
func (*PMProcess) GetProcess ¶
func (*PMProcess) GetStatus ¶
func (m *PMProcess) GetStatus() PMProcess_Status
func (*PMProcess) MarshalToSizedBuffer ¶
func (*PMProcess) ProtoMessage ¶
func (*PMProcess) ProtoMessage()
func (*PMProcess) VerboseEqual ¶
func (*PMProcess) XXX_DiscardUnknown ¶
func (m *PMProcess) XXX_DiscardUnknown()
func (*PMProcess) XXX_Marshal ¶
func (*PMProcess) XXX_Unmarshal ¶
type PMProcess_Status ¶
type PMProcess_Status int32
const ( PMProcess_DEFAULT PMProcess_Status = 0 PMProcess_NEW PMProcess_Status = 1 PMProcess_OPENED PMProcess_Status = 2 PMProcess_CLOSED PMProcess_Status = 3 )
func (PMProcess_Status) EnumDescriptor ¶
func (PMProcess_Status) EnumDescriptor() ([]byte, []int)
func (PMProcess_Status) MarshalText ¶
func (e PMProcess_Status) MarshalText() ([]byte, error)
MarshalText serialize a PMProcess_Status
func (PMProcess_Status) String ¶
func (x PMProcess_Status) String() string
func (*PMProcess_Status) UnmarshalText ¶
func (e *PMProcess_Status) UnmarshalText(data []byte) error
UnmarshalText parses a PMProcess_Status string
type PipelineInfo ¶
type PipelineInfo struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Status PipelineInfo_Status `protobuf:"varint,4,opt,name=status,proto3,enum=xbus.PipelineInfo_Status" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineInfo ¶
func NewPopulatedPipelineInfo(r randyXbus, easy bool) *PipelineInfo
func (*PipelineInfo) Descriptor ¶
func (*PipelineInfo) Descriptor() ([]byte, []int)
func (*PipelineInfo) Equal ¶
func (this *PipelineInfo) Equal(that interface{}) bool
func (*PipelineInfo) GetName ¶
func (m *PipelineInfo) GetName() string
func (*PipelineInfo) GetStatus ¶
func (m *PipelineInfo) GetStatus() PipelineInfo_Status
func (*PipelineInfo) GetVersion ¶
func (m *PipelineInfo) GetVersion() string
func (*PipelineInfo) GoString ¶
func (this *PipelineInfo) GoString() string
func (*PipelineInfo) Marshal ¶
func (m *PipelineInfo) Marshal() (dAtA []byte, err error)
func (*PipelineInfo) MarshalToSizedBuffer ¶
func (m *PipelineInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineInfo) ProtoMessage ¶
func (*PipelineInfo) ProtoMessage()
func (*PipelineInfo) Reset ¶
func (m *PipelineInfo) Reset()
func (*PipelineInfo) Size ¶
func (m *PipelineInfo) Size() (n int)
func (*PipelineInfo) String ¶
func (this *PipelineInfo) String() string
func (*PipelineInfo) Unmarshal ¶
func (m *PipelineInfo) Unmarshal(dAtA []byte) error
func (*PipelineInfo) VerboseEqual ¶
func (this *PipelineInfo) VerboseEqual(that interface{}) error
func (*PipelineInfo) XXX_DiscardUnknown ¶
func (m *PipelineInfo) XXX_DiscardUnknown()
func (*PipelineInfo) XXX_Marshal ¶
func (m *PipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineInfo) XXX_Merge ¶
func (m *PipelineInfo) XXX_Merge(src proto.Message)
func (*PipelineInfo) XXX_Size ¶
func (m *PipelineInfo) XXX_Size() int
func (*PipelineInfo) XXX_Unmarshal ¶
func (m *PipelineInfo) XXX_Unmarshal(b []byte) error
type PipelineInfo_Status ¶
type PipelineInfo_Status int32
const ( PipelineInfo_DRAFT PipelineInfo_Status = 0 PipelineInfo_ACTIVE PipelineInfo_Status = 1 PipelineInfo_INACTIVE PipelineInfo_Status = 2 )
func (PipelineInfo_Status) EnumDescriptor ¶
func (PipelineInfo_Status) EnumDescriptor() ([]byte, []int)
func (PipelineInfo_Status) MarshalText ¶
func (e PipelineInfo_Status) MarshalText() ([]byte, error)
MarshalText serialize a PipelineInfo_Status
func (PipelineInfo_Status) String ¶
func (x PipelineInfo_Status) String() string
func (*PipelineInfo_Status) UnmarshalText ¶
func (e *PipelineInfo_Status) UnmarshalText(data []byte) error
UnmarshalText parses a PipelineInfo_Status string
type Process ¶
type Process struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` TriggerEmitterID UUID `protobuf:"bytes,2,opt,name=triggerEmitterID,proto3,customtype=UUID" json:"triggerEmitterID"` TriggerEnvelopeID UUID `protobuf:"bytes,3,opt,name=triggerEnvelopeID,proto3,customtype=UUID" json:"triggerEnvelopeID"` PipelineID UUID `protobuf:"bytes,4,opt,name=pipelineID,proto3,customtype=UUID" json:"pipelineID"` Status Process_Status `protobuf:"varint,5,opt,name=status,proto3,enum=xbus.Process_Status" json:"status,omitempty"` State string `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"` CreatedAt *time.Time `protobuf:"bytes,7,opt,name=createdAt,proto3,stdtime" json:"createdAt,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcess ¶
func (*Process) Descriptor ¶
func (*Process) GetCreatedAt ¶
func (*Process) GetStatus ¶
func (m *Process) GetStatus() Process_Status
func (*Process) MarshalToSizedBuffer ¶
func (*Process) ProtoMessage ¶
func (*Process) ProtoMessage()
func (*Process) VerboseEqual ¶
func (*Process) XXX_DiscardUnknown ¶
func (m *Process) XXX_DiscardUnknown()
func (*Process) XXX_Marshal ¶
func (*Process) XXX_Unmarshal ¶
type ProcessFilter ¶
type ProcessFilter struct { ID []UUID `protobuf:"bytes,1,rep,name=id,proto3,customtype=UUID" json:"id"` TriggerEmitterID []UUID `protobuf:"bytes,2,rep,name=triggerEmitterID,proto3,customtype=UUID" json:"triggerEmitterID"` TriggerEnvelopeID []UUID `protobuf:"bytes,3,rep,name=triggerEnvelopeID,proto3,customtype=UUID" json:"triggerEnvelopeID"` /// The time range in which the process was created CreatedAt *TimeRange `protobuf:"bytes,10,opt,name=createdAt,proto3" json:"createdAt,omitempty"` PipelineID []UUID `protobuf:"bytes,4,rep,name=pipelineID,proto3,customtype=UUID" json:"pipelineID"` EnvelopeID []UUID `protobuf:"bytes,5,rep,name=envelopeID,proto3,customtype=UUID" json:"envelopeID"` Status []Process_Status `protobuf:"varint,6,rep,packed,name=status,proto3,enum=xbus.Process_Status" json:"status,omitempty"` /// Deprecated, should be set only if compatibility with xbus 3.0 is needed StatusChangedFrom *time.Time `protobuf:"bytes,7,opt,name=statusChangedFrom,proto3,stdtime" json:"statusChangedFrom,omitempty"` /// Deprecated, should be set only if compatibility with xbus 3.0 is needed StatusChangedTo *time.Time `protobuf:"bytes,8,opt,name=statusChangedTo,proto3,stdtime" json:"statusChangedTo,omitempty"` /// The time range in which the process changed its status for the last time StatusChanged *TimeRange `protobuf:"bytes,11,opt,name=statusChanged,proto3" json:"statusChanged,omitempty"` ResultAcked []bool `protobuf:"varint,9,rep,packed,name=resultAcked,proto3" json:"resultAcked,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessFilter ¶
func NewPopulatedProcessFilter(r randyXbus, easy bool) *ProcessFilter
func (*ProcessFilter) Descriptor ¶
func (*ProcessFilter) Descriptor() ([]byte, []int)
func (*ProcessFilter) Equal ¶
func (this *ProcessFilter) Equal(that interface{}) bool
func (*ProcessFilter) GetCreatedAt ¶
func (m *ProcessFilter) GetCreatedAt() *TimeRange
func (*ProcessFilter) GetResultAcked ¶
func (m *ProcessFilter) GetResultAcked() []bool
func (*ProcessFilter) GetStatus ¶
func (m *ProcessFilter) GetStatus() []Process_Status
func (*ProcessFilter) GetStatusChanged ¶
func (m *ProcessFilter) GetStatusChanged() *TimeRange
func (*ProcessFilter) GetStatusChangedFrom ¶
func (m *ProcessFilter) GetStatusChangedFrom() *time.Time
func (*ProcessFilter) GetStatusChangedTo ¶
func (m *ProcessFilter) GetStatusChangedTo() *time.Time
func (*ProcessFilter) GoString ¶
func (this *ProcessFilter) GoString() string
func (*ProcessFilter) Marshal ¶
func (m *ProcessFilter) Marshal() (dAtA []byte, err error)
func (*ProcessFilter) MarshalToSizedBuffer ¶
func (m *ProcessFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessFilter) ProtoMessage ¶
func (*ProcessFilter) ProtoMessage()
func (*ProcessFilter) Reset ¶
func (m *ProcessFilter) Reset()
func (*ProcessFilter) Size ¶
func (m *ProcessFilter) Size() (n int)
func (*ProcessFilter) String ¶
func (this *ProcessFilter) String() string
func (*ProcessFilter) Unmarshal ¶
func (m *ProcessFilter) Unmarshal(dAtA []byte) error
func (*ProcessFilter) VerboseEqual ¶
func (this *ProcessFilter) VerboseEqual(that interface{}) error
func (*ProcessFilter) XXX_DiscardUnknown ¶
func (m *ProcessFilter) XXX_DiscardUnknown()
func (*ProcessFilter) XXX_Marshal ¶
func (m *ProcessFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessFilter) XXX_Merge ¶
func (m *ProcessFilter) XXX_Merge(src proto.Message)
func (*ProcessFilter) XXX_Size ¶
func (m *ProcessFilter) XXX_Size() int
func (*ProcessFilter) XXX_Unmarshal ¶
func (m *ProcessFilter) XXX_Unmarshal(b []byte) error
type ProcessNodeReadyEvent ¶
type ProcessNodeReadyEvent struct { ProcessID UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=UUID" json:"processID"` ActorID UUID `protobuf:"bytes,2,opt,name=actorID,proto3,customtype=UUID" json:"actorID"` NodeID string `protobuf:"bytes,3,opt,name=nodeID,proto3" json:"nodeID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessNodeReadyEvent ¶
func NewPopulatedProcessNodeReadyEvent(r randyXbus, easy bool) *ProcessNodeReadyEvent
func (*ProcessNodeReadyEvent) Descriptor ¶
func (*ProcessNodeReadyEvent) Descriptor() ([]byte, []int)
func (*ProcessNodeReadyEvent) Equal ¶
func (this *ProcessNodeReadyEvent) Equal(that interface{}) bool
func (*ProcessNodeReadyEvent) GetNodeID ¶
func (m *ProcessNodeReadyEvent) GetNodeID() string
func (*ProcessNodeReadyEvent) GoString ¶
func (this *ProcessNodeReadyEvent) GoString() string
func (*ProcessNodeReadyEvent) Marshal ¶
func (m *ProcessNodeReadyEvent) Marshal() (dAtA []byte, err error)
func (*ProcessNodeReadyEvent) MarshalTo ¶
func (m *ProcessNodeReadyEvent) MarshalTo(dAtA []byte) (int, error)
func (*ProcessNodeReadyEvent) MarshalToSizedBuffer ¶
func (m *ProcessNodeReadyEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessNodeReadyEvent) ProtoMessage ¶
func (*ProcessNodeReadyEvent) ProtoMessage()
func (*ProcessNodeReadyEvent) Reset ¶
func (m *ProcessNodeReadyEvent) Reset()
func (*ProcessNodeReadyEvent) Size ¶
func (m *ProcessNodeReadyEvent) Size() (n int)
func (*ProcessNodeReadyEvent) String ¶
func (this *ProcessNodeReadyEvent) String() string
func (*ProcessNodeReadyEvent) Unmarshal ¶
func (m *ProcessNodeReadyEvent) Unmarshal(dAtA []byte) error
func (*ProcessNodeReadyEvent) VerboseEqual ¶
func (this *ProcessNodeReadyEvent) VerboseEqual(that interface{}) error
func (*ProcessNodeReadyEvent) XXX_DiscardUnknown ¶
func (m *ProcessNodeReadyEvent) XXX_DiscardUnknown()
func (*ProcessNodeReadyEvent) XXX_Marshal ¶
func (m *ProcessNodeReadyEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessNodeReadyEvent) XXX_Merge ¶
func (m *ProcessNodeReadyEvent) XXX_Merge(src proto.Message)
func (*ProcessNodeReadyEvent) XXX_Size ¶
func (m *ProcessNodeReadyEvent) XXX_Size() int
func (*ProcessNodeReadyEvent) XXX_Unmarshal ¶
func (m *ProcessNodeReadyEvent) XXX_Unmarshal(b []byte) error
type ProcessStateClient ¶
type ProcessStateClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewProcessStateClient ¶
func NewProcessStateClient(nc nrpc.NatsConn) *ProcessStateClient
func (*ProcessStateClient) AckResult ¶
func (c *ProcessStateClient) AckResult(emitterID string, req AckResultRequest) (err error)
func (*ProcessStateClient) EnvelopeStatesSubject ¶
func (c *ProcessStateClient) EnvelopeStatesSubject( mtemitterID string, mtenvelopeID string, ) string
func (*ProcessStateClient) EnvelopeStatesSubscribe ¶
func (c *ProcessStateClient) EnvelopeStatesSubscribe( mtemitterID string, mtenvelopeID string, handler func(EmitterEnvelopeState), ) (sub *nats.Subscription, err error)
func (*ProcessStateClient) EnvelopeStatesSubscribeChan ¶
func (c *ProcessStateClient) EnvelopeStatesSubscribeChan( mtemitterID string, mtenvelopeID string, ) (<-chan EmitterEnvelopeState, *nats.Subscription, error)
func (*ProcessStateClient) EnvelopeStatesSubscribeSync ¶
func (c *ProcessStateClient) EnvelopeStatesSubscribeSync( mtemitterID string, mtenvelopeID string, ) (sub *ProcessStateEnvelopeStatesSubscription, err error)
func (*ProcessStateClient) GetEnvelopeState ¶
func (c *ProcessStateClient) GetEnvelopeState(emitterID string, req GetEnvelopeStateRequest) (resp EmitterEnvelopeState, err error)
func (*ProcessStateClient) List ¶
func (c *ProcessStateClient) List( ctx context.Context, emitterID string, req ProcessFilter, cb func(context.Context, EmitterEnvelopeStateList), ) error
type ProcessStateEnvelopeStatesSubscription ¶
type ProcessStateEnvelopeStatesSubscription struct { *nats.Subscription // contains filtered or unexported fields }
func (*ProcessStateEnvelopeStatesSubscription) Next ¶
func (s *ProcessStateEnvelopeStatesSubscription) Next(timeout time.Duration) (next EmitterEnvelopeState, err error)
type ProcessStateHandler ¶
type ProcessStateHandler struct {
// contains filtered or unexported fields
}
ProcessStateHandler provides a NATS subscription handler that can serve a subscription using a given ProcessStateServer implementation.
func NewProcessStateConcurrentHandler ¶
func NewProcessStateConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ProcessStateServer) *ProcessStateHandler
func NewProcessStateHandler ¶
func NewProcessStateHandler(ctx context.Context, nc nrpc.NatsConn, s ProcessStateServer) *ProcessStateHandler
func (*ProcessStateHandler) EnvelopeStatesPublish ¶
func (h *ProcessStateHandler) EnvelopeStatesPublish(mtemitterID string, mtenvelopeID string, msg EmitterEnvelopeState) error
func (*ProcessStateHandler) Handler ¶
func (h *ProcessStateHandler) Handler(msg *nats.Msg)
func (*ProcessStateHandler) SetEncodings ¶
func (h *ProcessStateHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*ProcessStateHandler) Subject ¶
func (h *ProcessStateHandler) Subject() string
type ProcessStateServer ¶
type ProcessStateServer interface { GetEnvelopeState(ctx context.Context, emitterID string, req GetEnvelopeStateRequest) (resp EmitterEnvelopeState, err error) AckResult(ctx context.Context, emitterID string, req AckResultRequest) (err error) List(ctx context.Context, emitterID string, req ProcessFilter, pushRep func(EmitterEnvelopeStateList)) (err error) }
ProcessStateServer is the interface that providers of the service ProcessState should implement.
type Process_Status ¶
type Process_Status int32
const ( Process_NOSTATUS Process_Status = 0 Process_INITIAL Process_Status = 1 Process_RUNNING Process_Status = 2 Process_PAUSED Process_Status = 3 Process_DONE Process_Status = 4 Process_ERROR Process_Status = 5 )
func (Process_Status) EnumDescriptor ¶
func (Process_Status) EnumDescriptor() ([]byte, []int)
func (Process_Status) MarshalText ¶
func (e Process_Status) MarshalText() ([]byte, error)
MarshalText serialize a Process_Status
func (Process_Status) String ¶
func (x Process_Status) String() string
func (*Process_Status) UnmarshalText ¶
func (e *Process_Status) UnmarshalText(data []byte) error
UnmarshalText parses a Process_Status string
type ProcessingContext ¶
type ProcessingContext struct { ProcessID UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=UUID" json:"processID"` NodeID string `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessingContext ¶
func NewPopulatedProcessingContext(r randyXbus, easy bool) *ProcessingContext
func (*ProcessingContext) Descriptor ¶
func (*ProcessingContext) Descriptor() ([]byte, []int)
func (*ProcessingContext) Equal ¶
func (this *ProcessingContext) Equal(that interface{}) bool
func (*ProcessingContext) GetNodeID ¶
func (m *ProcessingContext) GetNodeID() string
func (*ProcessingContext) GoString ¶
func (this *ProcessingContext) GoString() string
func (*ProcessingContext) Marshal ¶
func (m *ProcessingContext) Marshal() (dAtA []byte, err error)
func (*ProcessingContext) MarshalTo ¶
func (m *ProcessingContext) MarshalTo(dAtA []byte) (int, error)
func (*ProcessingContext) MarshalToSizedBuffer ¶
func (m *ProcessingContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessingContext) ProtoMessage ¶
func (*ProcessingContext) ProtoMessage()
func (*ProcessingContext) Reset ¶
func (m *ProcessingContext) Reset()
func (*ProcessingContext) Size ¶
func (m *ProcessingContext) Size() (n int)
func (*ProcessingContext) String ¶
func (this *ProcessingContext) String() string
func (*ProcessingContext) Unmarshal ¶
func (m *ProcessingContext) Unmarshal(dAtA []byte) error
func (*ProcessingContext) VerboseEqual ¶
func (this *ProcessingContext) VerboseEqual(that interface{}) error
func (*ProcessingContext) XXX_DiscardUnknown ¶
func (m *ProcessingContext) XXX_DiscardUnknown()
func (*ProcessingContext) XXX_Marshal ¶
func (m *ProcessingContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessingContext) XXX_Merge ¶
func (m *ProcessingContext) XXX_Merge(src proto.Message)
func (*ProcessingContext) XXX_Size ¶
func (m *ProcessingContext) XXX_Size() int
func (*ProcessingContext) XXX_Unmarshal ¶
func (m *ProcessingContext) XXX_Unmarshal(b []byte) error
type Registration ¶
type Registration struct { ID UUID `protobuf:"bytes,1,opt,name=id,proto3,customtype=UUID" json:"id"` RegistrationStatus Registration_Status `protobuf:"varint,2,opt,name=registrationStatus,proto3,enum=xbus.Registration_Status" json:"registrationStatus,omitempty"` SignedCertificate string `protobuf:"bytes,3,opt,name=signedCertificate,proto3" json:"signedCertificate,omitempty"` ServerCA string `protobuf:"bytes,4,opt,name=serverCA,proto3" json:"serverCA,omitempty"` ActorList []Actor `protobuf:"bytes,5,rep,name=actorList,proto3" json:"actorList"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedRegistration ¶
func NewPopulatedRegistration(r randyXbus, easy bool) *Registration
func (*Registration) Descriptor ¶
func (*Registration) Descriptor() ([]byte, []int)
func (*Registration) Equal ¶
func (this *Registration) Equal(that interface{}) bool
func (*Registration) GetActorList ¶
func (m *Registration) GetActorList() []Actor
func (*Registration) GetRegistrationStatus ¶
func (m *Registration) GetRegistrationStatus() Registration_Status
func (*Registration) GetServerCA ¶
func (m *Registration) GetServerCA() string
func (*Registration) GetSignedCertificate ¶
func (m *Registration) GetSignedCertificate() string
func (*Registration) GoString ¶
func (this *Registration) GoString() string
func (*Registration) Marshal ¶
func (m *Registration) Marshal() (dAtA []byte, err error)
func (*Registration) MarshalToSizedBuffer ¶
func (m *Registration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Registration) ProtoMessage ¶
func (*Registration) ProtoMessage()
func (*Registration) Reset ¶
func (m *Registration) Reset()
func (*Registration) Size ¶
func (m *Registration) Size() (n int)
func (*Registration) String ¶
func (this *Registration) String() string
func (*Registration) Unmarshal ¶
func (m *Registration) Unmarshal(dAtA []byte) error
func (*Registration) VerboseEqual ¶
func (this *Registration) VerboseEqual(that interface{}) error
func (*Registration) XXX_DiscardUnknown ¶
func (m *Registration) XXX_DiscardUnknown()
func (*Registration) XXX_Marshal ¶
func (m *Registration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Registration) XXX_Merge ¶
func (m *Registration) XXX_Merge(src proto.Message)
func (*Registration) XXX_Size ¶
func (m *Registration) XXX_Size() int
func (*Registration) XXX_Unmarshal ¶
func (m *Registration) XXX_Unmarshal(b []byte) error
type RegistrationRequest ¶
type RegistrationRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type Account_Type `protobuf:"varint,2,opt,name=type,proto3,enum=xbus.Account_Type" json:"type,omitempty"` CSR string `protobuf:"bytes,3,opt,name=csr,proto3" json:"csr,omitempty"` ActorList []Actor `protobuf:"bytes,4,rep,name=actorList,proto3" json:"actorList"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedRegistrationRequest ¶
func NewPopulatedRegistrationRequest(r randyXbus, easy bool) *RegistrationRequest
func (*RegistrationRequest) Descriptor ¶
func (*RegistrationRequest) Descriptor() ([]byte, []int)
func (*RegistrationRequest) Equal ¶
func (this *RegistrationRequest) Equal(that interface{}) bool
func (*RegistrationRequest) GetActorList ¶
func (m *RegistrationRequest) GetActorList() []Actor
func (*RegistrationRequest) GetCSR ¶
func (m *RegistrationRequest) GetCSR() string
func (*RegistrationRequest) GetName ¶
func (m *RegistrationRequest) GetName() string
func (*RegistrationRequest) GetType ¶
func (m *RegistrationRequest) GetType() Account_Type
func (*RegistrationRequest) GoString ¶
func (this *RegistrationRequest) GoString() string
func (*RegistrationRequest) Marshal ¶
func (m *RegistrationRequest) Marshal() (dAtA []byte, err error)
func (*RegistrationRequest) MarshalTo ¶
func (m *RegistrationRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegistrationRequest) MarshalToSizedBuffer ¶
func (m *RegistrationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegistrationRequest) ProtoMessage ¶
func (*RegistrationRequest) ProtoMessage()
func (*RegistrationRequest) Reset ¶
func (m *RegistrationRequest) Reset()
func (*RegistrationRequest) Size ¶
func (m *RegistrationRequest) Size() (n int)
func (*RegistrationRequest) String ¶
func (this *RegistrationRequest) String() string
func (*RegistrationRequest) Unmarshal ¶
func (m *RegistrationRequest) Unmarshal(dAtA []byte) error
func (*RegistrationRequest) VerboseEqual ¶
func (this *RegistrationRequest) VerboseEqual(that interface{}) error
func (*RegistrationRequest) XXX_DiscardUnknown ¶
func (m *RegistrationRequest) XXX_DiscardUnknown()
func (*RegistrationRequest) XXX_Marshal ¶
func (m *RegistrationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegistrationRequest) XXX_Merge ¶
func (m *RegistrationRequest) XXX_Merge(src proto.Message)
func (*RegistrationRequest) XXX_Size ¶
func (m *RegistrationRequest) XXX_Size() int
func (*RegistrationRequest) XXX_Unmarshal ¶
func (m *RegistrationRequest) XXX_Unmarshal(b []byte) error
type Registration_Status ¶
type Registration_Status int32
const ( Registration_PENDING Registration_Status = 0 Registration_ACCEPTED Registration_Status = 1 Registration_REJECTED Registration_Status = 2 )
func (Registration_Status) EnumDescriptor ¶
func (Registration_Status) EnumDescriptor() ([]byte, []int)
func (Registration_Status) String ¶
func (x Registration_Status) String() string
type SentinelClient ¶
type SentinelClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewSentinelClient ¶
func NewSentinelClient(nc nrpc.NatsConn) *SentinelClient
func (*SentinelClient) ActorLeaving ¶
func (c *SentinelClient) ActorLeaving(actorID string) (err error)
func (*SentinelClient) ActorReady ¶
func (c *SentinelClient) ActorReady(actorID string) (err error)
func (*SentinelClient) ListActors ¶
func (c *SentinelClient) ListActors( ctx context.Context, cb func(context.Context, ClientGetActorsReply), ) error
func (*SentinelClient) SurveySubject ¶
func (c *SentinelClient) SurveySubject() string
func (*SentinelClient) SurveySubscribe ¶
func (c *SentinelClient) SurveySubscribe( handler func(SurveyRequest), ) (sub *nats.Subscription, err error)
func (*SentinelClient) SurveySubscribeChan ¶
func (c *SentinelClient) SurveySubscribeChan() (<-chan SurveyRequest, *nats.Subscription, error)
func (*SentinelClient) SurveySubscribeSync ¶
func (c *SentinelClient) SurveySubscribeSync() (sub *SentinelSurveySubscription, err error)
type SentinelHandler ¶
type SentinelHandler struct {
// contains filtered or unexported fields
}
SentinelHandler provides a NATS subscription handler that can serve a subscription using a given SentinelServer implementation.
func NewSentinelConcurrentHandler ¶
func NewSentinelConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s SentinelServer) *SentinelHandler
func NewSentinelHandler ¶
func NewSentinelHandler(ctx context.Context, nc nrpc.NatsConn, s SentinelServer) *SentinelHandler
func (*SentinelHandler) Handler ¶
func (h *SentinelHandler) Handler(msg *nats.Msg)
func (*SentinelHandler) SetEncodings ¶
func (h *SentinelHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*SentinelHandler) Subject ¶
func (h *SentinelHandler) Subject() string
func (*SentinelHandler) SurveyPublish ¶
func (h *SentinelHandler) SurveyPublish(msg SurveyRequest) error
type SentinelServer ¶
type SentinelServer interface { ActorReady(ctx context.Context, actorID string) ActorLeaving(ctx context.Context, actorID string) ListActors(ctx context.Context, pushRep func(ClientGetActorsReply)) (err error) }
SentinelServer is the interface that providers of the service Sentinel should implement.
type SentinelSurveySubscription ¶
type SentinelSurveySubscription struct { *nats.Subscription // contains filtered or unexported fields }
func (*SentinelSurveySubscription) Next ¶
func (s *SentinelSurveySubscription) Next(timeout time.Duration) (next SurveyRequest, err error)
type SessionToken ¶
type SessionToken struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` ValidUntil time.Time `protobuf:"bytes,2,opt,name=validUntil,proto3,stdtime" json:"validUntil"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedSessionToken ¶
func NewPopulatedSessionToken(r randyXbus, easy bool) *SessionToken
func (*SessionToken) Descriptor ¶
func (*SessionToken) Descriptor() ([]byte, []int)
func (*SessionToken) Equal ¶
func (this *SessionToken) Equal(that interface{}) bool
func (*SessionToken) GetToken ¶
func (m *SessionToken) GetToken() string
func (*SessionToken) GetValidUntil ¶
func (m *SessionToken) GetValidUntil() time.Time
func (*SessionToken) GoString ¶
func (this *SessionToken) GoString() string
func (*SessionToken) Marshal ¶
func (m *SessionToken) Marshal() (dAtA []byte, err error)
func (*SessionToken) MarshalToSizedBuffer ¶
func (m *SessionToken) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionToken) ProtoMessage ¶
func (*SessionToken) ProtoMessage()
func (*SessionToken) Reset ¶
func (m *SessionToken) Reset()
func (*SessionToken) Size ¶
func (m *SessionToken) Size() (n int)
func (*SessionToken) String ¶
func (this *SessionToken) String() string
func (*SessionToken) Unmarshal ¶
func (m *SessionToken) Unmarshal(dAtA []byte) error
func (*SessionToken) VerboseEqual ¶
func (this *SessionToken) VerboseEqual(that interface{}) error
func (*SessionToken) XXX_DiscardUnknown ¶
func (m *SessionToken) XXX_DiscardUnknown()
func (*SessionToken) XXX_Marshal ¶
func (m *SessionToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionToken) XXX_Merge ¶
func (m *SessionToken) XXX_Merge(src proto.Message)
func (*SessionToken) XXX_Size ¶
func (m *SessionToken) XXX_Size() int
func (*SessionToken) XXX_Unmarshal ¶
func (m *SessionToken) XXX_Unmarshal(b []byte) error
type StringReply ¶
type StringReply struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedStringReply ¶
func NewPopulatedStringReply(r randyXbus, easy bool) *StringReply
func (*StringReply) Descriptor ¶
func (*StringReply) Descriptor() ([]byte, []int)
func (*StringReply) Equal ¶
func (this *StringReply) Equal(that interface{}) bool
func (*StringReply) GetValue ¶
func (m *StringReply) GetValue() string
func (*StringReply) GoString ¶
func (this *StringReply) GoString() string
func (*StringReply) Marshal ¶
func (m *StringReply) Marshal() (dAtA []byte, err error)
func (*StringReply) MarshalToSizedBuffer ¶
func (m *StringReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StringReply) ProtoMessage ¶
func (*StringReply) ProtoMessage()
func (*StringReply) Reset ¶
func (m *StringReply) Reset()
func (*StringReply) Size ¶
func (m *StringReply) Size() (n int)
func (*StringReply) String ¶
func (this *StringReply) String() string
func (*StringReply) Unmarshal ¶
func (m *StringReply) Unmarshal(dAtA []byte) error
func (*StringReply) VerboseEqual ¶
func (this *StringReply) VerboseEqual(that interface{}) error
func (*StringReply) XXX_DiscardUnknown ¶
func (m *StringReply) XXX_DiscardUnknown()
func (*StringReply) XXX_Marshal ¶
func (m *StringReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StringReply) XXX_Merge ¶
func (m *StringReply) XXX_Merge(src proto.Message)
func (*StringReply) XXX_Size ¶
func (m *StringReply) XXX_Size() int
func (*StringReply) XXX_Unmarshal ¶
func (m *StringReply) XXX_Unmarshal(b []byte) error
type SurveyRequest ¶
type SurveyRequest struct { OnlineStatus bool `protobuf:"varint,1,opt,name=onlineStatus,proto3" json:"onlineStatus,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedSurveyRequest ¶
func NewPopulatedSurveyRequest(r randyXbus, easy bool) *SurveyRequest
func (*SurveyRequest) Descriptor ¶
func (*SurveyRequest) Descriptor() ([]byte, []int)
func (*SurveyRequest) Equal ¶
func (this *SurveyRequest) Equal(that interface{}) bool
func (*SurveyRequest) GetOnlineStatus ¶
func (m *SurveyRequest) GetOnlineStatus() bool
func (*SurveyRequest) GoString ¶
func (this *SurveyRequest) GoString() string
func (*SurveyRequest) Marshal ¶
func (m *SurveyRequest) Marshal() (dAtA []byte, err error)
func (*SurveyRequest) MarshalToSizedBuffer ¶
func (m *SurveyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SurveyRequest) ProtoMessage ¶
func (*SurveyRequest) ProtoMessage()
func (*SurveyRequest) Reset ¶
func (m *SurveyRequest) Reset()
func (*SurveyRequest) Size ¶
func (m *SurveyRequest) Size() (n int)
func (*SurveyRequest) String ¶
func (this *SurveyRequest) String() string
func (*SurveyRequest) Unmarshal ¶
func (m *SurveyRequest) Unmarshal(dAtA []byte) error
func (*SurveyRequest) VerboseEqual ¶
func (this *SurveyRequest) VerboseEqual(that interface{}) error
func (*SurveyRequest) XXX_DiscardUnknown ¶
func (m *SurveyRequest) XXX_DiscardUnknown()
func (*SurveyRequest) XXX_Marshal ¶
func (m *SurveyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SurveyRequest) XXX_Merge ¶
func (m *SurveyRequest) XXX_Merge(src proto.Message)
func (*SurveyRequest) XXX_Size ¶
func (m *SurveyRequest) XXX_Size() int
func (*SurveyRequest) XXX_Unmarshal ¶
func (m *SurveyRequest) XXX_Unmarshal(b []byte) error
type SvcRegistrationClient ¶
type SvcRegistrationClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewSvcRegistrationClient ¶
func NewSvcRegistrationClient(nc nrpc.NatsConn) *SvcRegistrationClient
func (*SvcRegistrationClient) Register ¶
func (c *SvcRegistrationClient) Register(req RegistrationRequest) (resp Registration, err error)
func (*SvcRegistrationClient) Update ¶
func (c *SvcRegistrationClient) Update(accountID string, req RegistrationRequest) (resp Registration, err error)
type SvcRegistrationHandler ¶
type SvcRegistrationHandler struct {
// contains filtered or unexported fields
}
SvcRegistrationHandler provides a NATS subscription handler that can serve a subscription using a given SvcRegistrationServer implementation.
func NewSvcRegistrationConcurrentHandler ¶
func NewSvcRegistrationConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s SvcRegistrationServer) *SvcRegistrationHandler
func NewSvcRegistrationHandler ¶
func NewSvcRegistrationHandler(ctx context.Context, nc nrpc.NatsConn, s SvcRegistrationServer) *SvcRegistrationHandler
func (*SvcRegistrationHandler) Handler ¶
func (h *SvcRegistrationHandler) Handler(msg *nats.Msg)
func (*SvcRegistrationHandler) SetEncodings ¶
func (h *SvcRegistrationHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*SvcRegistrationHandler) Subject ¶
func (h *SvcRegistrationHandler) Subject() string
type SvcRegistrationServer ¶
type SvcRegistrationServer interface { Register(ctx context.Context, req RegistrationRequest) (resp Registration, err error) Update(ctx context.Context, accountID string, req RegistrationRequest) (resp Registration, err error) }
SvcRegistrationServer is the interface that providers of the service SvcRegistration should implement.
type TimeRange ¶
type TimeRange struct { From *time.Time `protobuf:"bytes,1,opt,name=from,proto3,stdtime" json:"from,omitempty"` To *time.Time `protobuf:"bytes,2,opt,name=to,proto3,stdtime" json:"to,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedTimeRange ¶
func (*TimeRange) Descriptor ¶
func (*TimeRange) IsZero ¶
IsZero returns true if the TimeRange is unset (ie is nil or has both To and From undefined
func (*TimeRange) MarshalToSizedBuffer ¶
func (*TimeRange) ProtoMessage ¶
func (*TimeRange) ProtoMessage()
func (*TimeRange) VerboseEqual ¶
func (*TimeRange) XXX_DiscardUnknown ¶
func (m *TimeRange) XXX_DiscardUnknown()
func (*TimeRange) XXX_Marshal ¶
func (*TimeRange) XXX_Unmarshal ¶
type UUID ¶
UUID is thin wrapper of m4rw3r/uuid.UUID that implements the needed interfaces for being used as gogo/protobuf
func MaybeUUIDFromString ¶
MaybeUUIDFromString reads a UUID into a new UUID instance, setting the instance to zero if it fails.
func MustUUIDFromString ¶
MustUUIDFromString parses and returns a UUID, and panics if it fails to do so
func NewPopulatedUUID ¶
func NewPopulatedUUID(r randyUUID) *UUID
NewPopulatedUUID implements V4 with a randy source
func UUIDFromString ¶
UUIDFromString parses and returns a UUID
func (UUID) MarshalJSON ¶
MarshalJSON returns the string-representation of the UUID as a JSON-string.
func (UUID) MarshalText ¶
MarshalText returns the string-representation of the UUID as a byte-array.
func (*UUID) ReadBytes ¶
ReadBytes reads the supplied byte array of hexadecimal characters representing a UUID into the instance.
func (*UUID) UnmarshalJSON ¶
UnmarshalJSON reads an UUID from a JSON-string into the UUID instance. If this fails the state of the UUID is undetermined.
func (*UUID) UnmarshalText ¶
UnmarshalText reads an UUID from a string into the UUID instance. If this fails the state of the UUID is undetermined.
type WhoAmIClient ¶
type WhoAmIClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewWhoAmIClient ¶
func NewWhoAmIClient(nc nrpc.NatsConn) *WhoAmIClient
type WhoAmIHandler ¶
type WhoAmIHandler struct {
// contains filtered or unexported fields
}
WhoAmIHandler provides a NATS subscription handler that can serve a subscription using a given WhoAmIServer implementation.
func NewWhoAmIConcurrentHandler ¶
func NewWhoAmIConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s WhoAmIServer) *WhoAmIHandler
func NewWhoAmIHandler ¶
func NewWhoAmIHandler(ctx context.Context, nc nrpc.NatsConn, s WhoAmIServer) *WhoAmIHandler
func (*WhoAmIHandler) Handler ¶
func (h *WhoAmIHandler) Handler(msg *nats.Msg)
func (*WhoAmIHandler) SetEncodings ¶
func (h *WhoAmIHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*WhoAmIHandler) Subject ¶
func (h *WhoAmIHandler) Subject() string