api

package
v3.3.3 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2023 License: MIT Imports: 25 Imported by: 33

Documentation

Overview

This code was autogenerated from xbus/xbus.proto, do not edit.

Index

Constants

View Source 
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"
)
View Source 
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."
)
View Source 
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"
)
View Source 
const (
	// EmissionServicePrefix is the prefix for the emission service
	EmissionServicePrefix = ServicesPrefix + "emission."

	// EmissionSignalSubjet is the subject for sending EmissionSignal messages
	EmissionSignalSubjet = EmissionServicePrefix + "signal"
)
View Source 
const (
	// ClientPrefix is the prefix for client api subjects
	ClientPrefix = XbusAPIPrefix + "client."
)
View Source 
const (
	// ProcessStatePrefix is the prefix for process state apis
	ProcessStatePrefix = XbusAPIPrefix + "processstate."
)
View Source 
const RegistrationSubject = XbusAPIPrefix + "registration"

RegistrationSubject is the subject for registration requests

Variables

View Source 
var (
	ErrInvalidLengthXbus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowXbus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupXbus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Account_CSROrigin_name = map[int32]string{
	0: "ANONYMOUS",
	1: "AUTHACCOUNT",
}
View Source 
var Account_CSROrigin_value = map[string]int32{
	"ANONYMOUS":   0,
	"AUTHACCOUNT": 1,
}
View Source 
var Account_Status_name = map[int32]string{
	0: "NOSTATUS",
	1: "PENDING",
	2: "ENABLED",
	3: "DISABLED",
}
View Source 
var Account_Status_value = map[string]int32{
	"NOSTATUS": 0,
	"PENDING":  1,
	"ENABLED":  2,
	"DISABLED": 3,
}
View Source 
var Account_Type_name = map[int32]string{
	0: "NOTYPE",
	1: "ACTOR",
	2: "USER",
	3: "GATEWAY",
}
View Source 
var Account_Type_value = map[string]int32{
	"NOTYPE":  0,
	"ACTOR":   1,
	"USER":    2,
	"GATEWAY": 3,
}
View Source 
var ActorProcessingState_Status_name = map[int32]string{
	0: "PENDING",
	1: "RUNNING",
	2: "SUCCESS",
	3: "ERROR",
}
View Source 
var ActorProcessingState_Status_value = map[string]int32{
	"PENDING": 0,
	"RUNNING": 1,
	"SUCCESS": 2,
	"ERROR":   3,
}
View Source 
var Actor_Kind_name = map[int32]string{
	0: "CONSUMER",
	1: "EMITTER",
	2: "WORKER",
}
View Source 
var Actor_Kind_value = map[string]int32{
	"CONSUMER": 0,
	"EMITTER":  1,
	"WORKER":   2,
}
View Source 
var Actor_Status_name = map[int32]string{
	0: "PENDING",
	1: "ENABLED",
	2: "DISABLED",
	3: "REJECTED",
}
View Source 
var Actor_Status_value = map[string]int32{
	"PENDING":  0,
	"ENABLED":  1,
	"DISABLED": 2,
	"REJECTED": 3,
}
View Source 
var EnvelopeAck_ReceptionStatus_name = map[int32]string{
	0: "NOSTATUS",
	1: "RECEIVING",
	2: "ACCEPTED",
	3: "ERROR",
}
View Source 
var EnvelopeAck_ReceptionStatus_value = map[string]int32{
	"NOSTATUS":  0,
	"RECEIVING": 1,
	"ACCEPTED":  2,
	"ERROR":     3,
}
View Source 
var EnvelopeEvent_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "RECEIVING",
	3: "COMPLETE",
	4: "ERROR",
	5: "STALLED",
}
View Source 
var EnvelopeEvent_Status_value = map[string]int32{
	"UNKNOWN":   0,
	"RECEIVING": 1,
	"COMPLETE":  3,
	"ERROR":     4,
	"STALLED":   5,
}
View Source 
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
)
View Source 
var LogLevel_name = map[int32]string{
	0: "NOTICE",
	1: "WARNING",
	2: "ERROR",
}
View Source 
var LogLevel_value = map[string]int32{
	"NOTICE":  0,
	"WARNING": 1,
	"ERROR":   2,
}
View Source 
var PMProcess_Status_name = map[int32]string{
	0: "DEFAULT",
	1: "NEW",
	2: "OPENED",
	3: "CLOSED",
}
View Source 
var PMProcess_Status_value = map[string]int32{
	"DEFAULT": 0,
	"NEW":     1,
	"OPENED":  2,
	"CLOSED":  3,
}
View Source 
var PipelineInfo_Status_name = map[int32]string{
	0: "DRAFT",
	1: "ACTIVE",
	2: "INACTIVE",
}
View Source 
var PipelineInfo_Status_value = map[string]int32{
	"DRAFT":    0,
	"ACTIVE":   1,
	"INACTIVE": 2,
}
View Source 
var Process_Status_name = map[int32]string{
	0: "NOSTATUS",
	1: "INITIAL",
	2: "RUNNING",
	3: "PAUSED",
	4: "DONE",
	5: "ERROR",
}
View Source 
var Process_Status_value = map[string]int32{
	"NOSTATUS": 0,
	"INITIAL":  1,
	"RUNNING":  2,
	"PAUSED":   3,
	"DONE":     4,
	"ERROR":    5,
}
View Source 
var Registration_Status_name = map[int32]string{
	0: "PENDING",
	1: "ACCEPTED",
	2: "REJECTED",
}
View Source 
var Registration_Status_value = map[string]int32{
	"PENDING":  0,
	"ACCEPTED": 1,
	"REJECTED": 2,
}

Functions

func ActorInputSubject 

func ActorInputSubject(id UUID, output string) string

ActorInputSubject returns the subject for an actor input

func ActorOutputSubject 

func ActorOutputSubject(id UUID) string

ActorOutputSubject returns the subject for an actor output

func ClientProtoError 

func ClientProtoError(msg string, fmtArgs ...interface{}) *nrpc.Error

ClientProtoError returns a client error nrpc.Error

func EmitterEnvelopeStateSubject 

func EmitterEnvelopeStateSubject(emitter UUID, envelopeID UUID) string

EmitterEnvelopeStateSubject returns the subject on which process events are sent

func EmitterMsgboxSubject 

func EmitterMsgboxSubject(id UUID) string

EmitterMsgboxSubject returns the msgbox for an emitter

func ItemsAsChunks 

func ItemsAsChunks(items []Item) [][]byte

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 

func ServerProtoError(err error) *nrpc.Error

ServerProtoError returns a server error nrpc.Error

func UUIDToStringOrWildcard 

func UUIDToStringOrWildcard(value UUID) string

UUIDToStringOrWildcard return '*' if the value is zero, and the value.String() result otherwise

func WhoAmISubjects 

func WhoAmISubjects(apiKey string) (string, string)

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 NewPopulatedAccount(r randyXbus, easy bool) *Account

func (*Account) Descriptor 

func (*Account) Descriptor() ([]byte, []int)

func (*Account) Equal 

func (this *Account) Equal(that interface{}) bool

func (*Account) GetAPIKey 

func (m *Account) GetAPIKey() string

func (*Account) GetCSR 

func (m *Account) GetCSR() string

func (*Account) GetCSROrigin 

func (m *Account) GetCSROrigin() Account_CSROrigin

func (*Account) GetCert 

func (m *Account) GetCert() string

func (*Account) GetName 

func (m *Account) GetName() string

func (*Account) GetStatus 

func (m *Account) GetStatus() Account_Status

func (*Account) GetType 

func (m *Account) GetType() Account_Type

func (*Account) GoString 

func (this *Account) GoString() string

func (*Account) Marshal 

func (m *Account) Marshal() (dAtA []byte, err error)

func (*Account) MarshalTo 

func (m *Account) MarshalTo(dAtA []byte) (int, error)

func (*Account) MarshalToSizedBuffer 

func (m *Account) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) Reset 

func (m *Account) Reset()

func (*Account) Size 

func (m *Account) Size() (n int)

func (*Account) String 

func (this *Account) String() string

func (*Account) Unmarshal 

func (m *Account) Unmarshal(dAtA []byte) error

func (*Account) VerboseEqual 

func (this *Account) VerboseEqual(that interface{}) error

func (*Account) XXX_DiscardUnknown 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal 

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

func (*Account) XXX_Merge 

func (m *Account) XXX_Merge(src proto.Message)

func (*Account) XXX_Size 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal 

func (m *Account) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *AckResultRequest) MarshalTo(dAtA []byte) (int, 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 NewPopulatedActor(r randyXbus, easy bool) *Actor

func (*Actor) Descriptor 

func (*Actor) Descriptor() ([]byte, []int)

func (*Actor) Equal 

func (this *Actor) Equal(that interface{}) bool

func (*Actor) GetConfig 

func (m *Actor) GetConfig() []ConfigEntry

func (*Actor) GetConfigEntry 

func (a *Actor) GetConfigEntry(key string) string

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 (m *Actor) GetLastSeen() time.Time

func (*Actor) GetName 

func (m *Actor) GetName() string

func (*Actor) GetOnline 

func (m *Actor) GetOnline() bool

func (*Actor) GetRoles 

func (m *Actor) GetRoles() []string

func (*Actor) GetStatus 

func (m *Actor) GetStatus() Actor_Status

func (*Actor) GetUnresponsive 

func (m *Actor) GetUnresponsive() bool

func (*Actor) GoString 

func (this *Actor) GoString() string

func (*Actor) Marshal 

func (m *Actor) Marshal() (dAtA []byte, err error)

func (*Actor) MarshalTo 

func (m *Actor) MarshalTo(dAtA []byte) (int, error)

func (*Actor) MarshalToSizedBuffer 

func (m *Actor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Actor) ProtoMessage 

func (*Actor) ProtoMessage()

func (*Actor) Reset 

func (m *Actor) Reset()

func (*Actor) Size 

func (m *Actor) Size() (n int)

func (*Actor) String 

func (this *Actor) String() string

func (*Actor) Unmarshal 

func (m *Actor) Unmarshal(dAtA []byte) error

func (*Actor) VerboseEqual 

func (this *Actor) VerboseEqual(that interface{}) error

func (*Actor) XXX_DiscardUnknown 

func (m *Actor) XXX_DiscardUnknown()

func (*Actor) XXX_Marshal 

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

func (*Actor) XXX_Merge 

func (m *Actor) XXX_Merge(src proto.Message)

func (*Actor) XXX_Size 

func (m *Actor) XXX_Size() int

func (*Actor) XXX_Unmarshal 

func (m *Actor) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *ActorLogRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ActorReadyMsg) MarshalTo(dAtA []byte) (int, 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 Checksum 

type Checksum uint32

Checksum stores checksums

func (Checksum) Update 

func (c Checksum) Update(data []byte) Checksum

Update updates the checksum with more data

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 NewClient 

func NewClient(nc nrpc.NatsConn) *Client

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 (c *Client) SetActorAgentParams(
	actorID string,
)

func (*Client) SetBrokerParams 

func (c *Client) SetBrokerParams(
	actorID string,
)

func (*Client) SetClientAPIParams 

func (c *Client) SetClientAPIParams(
	accountID string,
)

func (*Client) SetEncoding 

func (c *Client) SetEncoding(encoding string)

func (*Client) SetTimeout 

func (c *Client) SetTimeout(t time.Duration)

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) MarshalTo 

func (m *ConfigEntry) MarshalTo(dAtA []byte) (int, 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 NewPopulatedCoreEvent(r randyXbus, easy bool) *CoreEvent

func (*CoreEvent) Descriptor 

func (*CoreEvent) Descriptor() ([]byte, []int)

func (*CoreEvent) Equal 

func (this *CoreEvent) Equal(that interface{}) bool

func (*CoreEvent) GetActor 

func (m *CoreEvent) GetActor() *Actor

func (*CoreEvent) GetName 

func (m *CoreEvent) GetName() string

func (*CoreEvent) GetProcess 

func (m *CoreEvent) GetProcess() *Process

func (*CoreEvent) GetProcessOldStatus 

func (m *CoreEvent) GetProcessOldStatus() Process_Status

func (*CoreEvent) GoString 

func (this *CoreEvent) GoString() string

func (*CoreEvent) Marshal 

func (m *CoreEvent) Marshal() (dAtA []byte, err error)

func (*CoreEvent) MarshalTo 

func (m *CoreEvent) MarshalTo(dAtA []byte) (int, error)

func (*CoreEvent) MarshalToSizedBuffer 

func (m *CoreEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CoreEvent) ProtoMessage 

func (*CoreEvent) ProtoMessage()

func (*CoreEvent) Reset 

func (m *CoreEvent) Reset()

func (*CoreEvent) Size 

func (m *CoreEvent) Size() (n int)

func (*CoreEvent) String 

func (this *CoreEvent) String() string

func (*CoreEvent) Unmarshal 

func (m *CoreEvent) Unmarshal(dAtA []byte) error

func (*CoreEvent) VerboseEqual 

func (this *CoreEvent) VerboseEqual(that interface{}) error

func (*CoreEvent) XXX_DiscardUnknown 

func (m *CoreEvent) XXX_DiscardUnknown()

func (*CoreEvent) XXX_Marshal 

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

func (*CoreEvent) XXX_Merge 

func (m *CoreEvent) XXX_Merge(src proto.Message)

func (*CoreEvent) XXX_Size 

func (m *CoreEvent) XXX_Size() int

func (*CoreEvent) XXX_Unmarshal 

func (m *CoreEvent) XXX_Unmarshal(b []byte) error

type CoreEventsActorSubscription 

type CoreEventsActorSubscription struct {
	*nats.Subscription
	// contains filtered or unexported fields
}

func (*CoreEventsActorSubscription) Next 

func (s *CoreEventsActorSubscription) Next(timeout time.Duration) (next CoreEvent, err error)

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
}

func (*CoreEventsProcessSubscription) Next 

func (s *CoreEventsProcessSubscription) Next(timeout time.Duration) (next CoreEvent, err error)

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 NewPopulatedEnvelope(r randyXbus, easy bool) *Envelope

func (*Envelope) Descriptor 

func (*Envelope) Descriptor() ([]byte, []int)

func (*Envelope) Equal 

func (this *Envelope) Equal(that interface{}) bool

func (*Envelope) GetEvents 

func (m *Envelope) GetEvents() []Event

func (*Envelope) GetLast 

func (m *Envelope) GetLast() bool

func (*Envelope) GoString 

func (this *Envelope) GoString() string

func (*Envelope) Marshal 

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo 

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) MarshalToSizedBuffer 

func (m *Envelope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Envelope) Merge added in v3.3.0 

func (envelope *Envelope) Merge(fragment ...*Envelope) error

Merge some envelope fragments into this envelope

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) Reset 

func (m *Envelope) Reset()

func (*Envelope) Size 

func (m *Envelope) Size() (n int)

func (*Envelope) String 

func (this *Envelope) String() string

func (*Envelope) Unmarshal 

func (m *Envelope) Unmarshal(dAtA []byte) error

func (*Envelope) VerboseEqual 

func (this *Envelope) VerboseEqual(that interface{}) error

func (*Envelope) XXX_DiscardUnknown 

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal 

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

func (*Envelope) XXX_Merge 

func (m *Envelope) XXX_Merge(src proto.Message)

func (*Envelope) XXX_Size 

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal 

func (m *Envelope) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *EnvelopeAck) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *EnvelopeEvent) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *EnvelopePosition) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *EnvelopeTarget) MarshalTo(dAtA []byte) (int, 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 NewPopulatedEvent(r randyXbus, easy bool) *Event

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) Equal 

func (this *Event) Equal(that interface{}) bool

func (*Event) GetChecksum 

func (m *Event) GetChecksum() Checksum

func (*Event) GetIndex 

func (m *Event) GetIndex() uint64

func (*Event) GetItemCount 

func (m *Event) GetItemCount() uint64

func (*Event) GetItems 

func (m *Event) GetItems() []Item

func (*Event) GetType 

func (m *Event) GetType() string

func (*Event) GoString 

func (this *Event) GoString() string

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (Event) MarshalJSONPB 

func (event Event) MarshalJSONPB(m *jsonpb.Marshaler) ([]byte, error)

MarshalJSONPB encode a Event with an additional "encoding" that is the actual encoding of the items

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (this *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) UnmarshalJSON 

func (event *Event) UnmarshalJSON(data []byte) error

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 (this *Event) VerboseEqual(that interface{}) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *EventPosition) MarshalTo(dAtA []byte) (int, 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 

func ChunksAsItems(chunks [][]byte) []Item

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 

func (item Item) MarshalYAML() (interface{}, error)

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 NewPopulatedLogEntry(r randyXbus, easy bool) *LogEntry

func (*LogEntry) Descriptor 

func (*LogEntry) Descriptor() ([]byte, []int)

func (*LogEntry) Equal 

func (this *LogEntry) Equal(that interface{}) bool

func (*LogEntry) GetMessage 

func (m *LogEntry) GetMessage() LogMessage

func (*LogEntry) GetNodeID 

func (m *LogEntry) GetNodeID() string

func (*LogEntry) GoString 

func (this *LogEntry) GoString() string

func (*LogEntry) Marshal 

func (m *LogEntry) Marshal() (dAtA []byte, err error)

func (*LogEntry) MarshalTo 

func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*LogEntry) MarshalToSizedBuffer 

func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

func (m *LogEntry) Size() (n int)

func (*LogEntry) String 

func (this *LogEntry) String() string

func (*LogEntry) Unmarshal 

func (m *LogEntry) Unmarshal(dAtA []byte) error

func (*LogEntry) VerboseEqual 

func (this *LogEntry) VerboseEqual(that interface{}) error

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type LogLevel 

type LogLevel int32

* Defines the severity of a log entry 

const (
	LogLevel_NOTICE  LogLevel = 0
	LogLevel_WARNING LogLevel = 1
	LogLevel_ERROR   LogLevel = 2
)

func (LogLevel) EnumDescriptor 

func (LogLevel) EnumDescriptor() ([]byte, []int)

func (LogLevel) MarshalText 

func (e LogLevel) MarshalText() ([]byte, error)

MarshalText serialize a LogLevel

func (LogLevel) String 

func (x LogLevel) String() string

func (*LogLevel) UnmarshalText 

func (e *LogLevel) UnmarshalText(data []byte) error

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) MarshalTo 

func (m *LogMessage) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *OutputRequest) MarshalTo(dAtA []byte) (int, 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 NewPopulatedPMProcess(r randyXbus, easy bool) *PMProcess

func (*PMProcess) Descriptor 

func (*PMProcess) Descriptor() ([]byte, []int)

func (*PMProcess) Equal 

func (this *PMProcess) Equal(that interface{}) bool

func (*PMProcess) GetComment 

func (m *PMProcess) GetComment() string

func (*PMProcess) GetLevel 

func (m *PMProcess) GetLevel() LogLevel

func (*PMProcess) GetLogs 

func (m *PMProcess) GetLogs() []LogEntry

func (*PMProcess) GetProcess 

func (m *PMProcess) GetProcess() Process

func (*PMProcess) GetStatus 

func (m *PMProcess) GetStatus() PMProcess_Status

func (*PMProcess) GoString 

func (this *PMProcess) GoString() string

func (*PMProcess) Marshal 

func (m *PMProcess) Marshal() (dAtA []byte, err error)

func (*PMProcess) MarshalTo 

func (m *PMProcess) MarshalTo(dAtA []byte) (int, error)

func (*PMProcess) MarshalToSizedBuffer 

func (m *PMProcess) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PMProcess) ProtoMessage 

func (*PMProcess) ProtoMessage()

func (*PMProcess) Reset 

func (m *PMProcess) Reset()

func (*PMProcess) Size 

func (m *PMProcess) Size() (n int)

func (*PMProcess) String 

func (this *PMProcess) String() string

func (*PMProcess) Unmarshal 

func (m *PMProcess) Unmarshal(dAtA []byte) error

func (*PMProcess) VerboseEqual 

func (this *PMProcess) VerboseEqual(that interface{}) error

func (*PMProcess) XXX_DiscardUnknown 

func (m *PMProcess) XXX_DiscardUnknown()

func (*PMProcess) XXX_Marshal 

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

func (*PMProcess) XXX_Merge 

func (m *PMProcess) XXX_Merge(src proto.Message)

func (*PMProcess) XXX_Size 

func (m *PMProcess) XXX_Size() int

func (*PMProcess) XXX_Unmarshal 

func (m *PMProcess) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *PipelineInfo) MarshalTo(dAtA []byte) (int, 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"`
	GroupID              UUID           `protobuf:"bytes,8,opt,name=groupID,proto3,customtype=UUID" json:"groupID"`
	ReplayOf             UUID           `protobuf:"bytes,9,opt,name=replayOf,proto3,customtype=UUID" json:"replayOf"`
	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 NewPopulatedProcess(r randyXbus, easy bool) *Process

func (*Process) Descriptor 

func (*Process) Descriptor() ([]byte, []int)

func (*Process) Equal 

func (this *Process) Equal(that interface{}) bool

func (*Process) GetCreatedAt 

func (m *Process) GetCreatedAt() *time.Time

func (*Process) GetState 

func (m *Process) GetState() string

func (*Process) GetStatus 

func (m *Process) GetStatus() Process_Status

func (*Process) GoString 

func (this *Process) GoString() string

func (*Process) Marshal 

func (m *Process) Marshal() (dAtA []byte, err error)

func (*Process) MarshalTo 

func (m *Process) MarshalTo(dAtA []byte) (int, error)

func (*Process) MarshalToSizedBuffer 

func (m *Process) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) Size 

func (m *Process) Size() (n int)

func (*Process) String 

func (this *Process) String() string

func (*Process) Unmarshal 

func (m *Process) Unmarshal(dAtA []byte) error

func (*Process) VerboseEqual 

func (this *Process) VerboseEqual(that interface{}) error

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

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

func (*Process) XXX_Merge 

func (m *Process) XXX_Merge(src proto.Message)

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

func (m *Process) XXX_Unmarshal(b []byte) error

type ProcessFilter 

type ProcessFilter struct {
	ID                []UUID `protobuf:"bytes,1,rep,name=id,proto3,customtype=UUID" json:"id"`
	GroupID           []UUID `protobuf:"bytes,12,rep,name=groupID,proto3,customtype=UUID" json:"groupID"`
	ReplayOf          []UUID `protobuf:"bytes,13,rep,name=replayOf,proto3,customtype=UUID" json:"replayOf"`
	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) MarshalTo 

func (m *ProcessFilter) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *Registration) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SessionToken) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StringReply) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SurveyRequest) MarshalTo(dAtA []byte) (int, 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 NewPopulatedTimeRange(r randyXbus, easy bool) *TimeRange

func (*TimeRange) Descriptor 

func (*TimeRange) Descriptor() ([]byte, []int)

func (*TimeRange) Equal 

func (this *TimeRange) Equal(that interface{}) bool

func (*TimeRange) GetFrom 

func (m *TimeRange) GetFrom() *time.Time

func (*TimeRange) GetTo 

func (m *TimeRange) GetTo() *time.Time

func (*TimeRange) GoString 

func (this *TimeRange) GoString() string

func (*TimeRange) IsZero 

func (m *TimeRange) IsZero() bool

IsZero returns true if the TimeRange is unset (ie is nil or has both To and From undefined

func (*TimeRange) Marshal 

func (m *TimeRange) Marshal() (dAtA []byte, err error)

func (*TimeRange) MarshalTo 

func (m *TimeRange) MarshalTo(dAtA []byte) (int, error)

func (*TimeRange) MarshalToSizedBuffer 

func (m *TimeRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset 

func (m *TimeRange) Reset()

func (*TimeRange) Size 

func (m *TimeRange) Size() (n int)

func (*TimeRange) String 

func (this *TimeRange) String() string

func (*TimeRange) Unmarshal 

func (m *TimeRange) Unmarshal(dAtA []byte) error

func (*TimeRange) VerboseEqual 

func (this *TimeRange) VerboseEqual(that interface{}) error

func (*TimeRange) XXX_DiscardUnknown 

func (m *TimeRange) XXX_DiscardUnknown()

func (*TimeRange) XXX_Marshal 

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

func (*TimeRange) XXX_Merge 

func (m *TimeRange) XXX_Merge(src proto.Message)

func (*TimeRange) XXX_Size 

func (m *TimeRange) XXX_Size() int

func (*TimeRange) XXX_Unmarshal 

func (m *TimeRange) XXX_Unmarshal(b []byte) error

type UUID 

type UUID muuid.UUID

UUID is thin wrapper of m4rw3r/uuid.UUID that implements the needed interfaces for being used as gogo/protobuf

func MaybeUUIDFromString 

func MaybeUUIDFromString(s string) UUID

MaybeUUIDFromString reads a UUID into a new UUID instance, setting the instance to zero if it fails.

func MustUUIDFromString 

func MustUUIDFromString(s string) UUID

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 

func UUIDFromString(s string) (UUID, error)

UUIDFromString parses and returns a UUID

func UUIDV4 

func UUIDV4() (UUID, error)

UUIDV4 creates a UUID from rand

func (UUID) Compare 

func (uuid UUID) Compare(other UUID) int

Compare compares two value

func (UUID) Equal 

func (uuid UUID) Equal(other UUID) bool

Equal returns true if the two values are equal. Needed by gogo/protobuf

func (UUID) IsZero 

func (uuid UUID) IsZero() bool

IsZero returns true if the uuid has only zeros

func (UUID) Marshal 

func (uuid UUID) Marshal() ([]byte, error)

Marshal returns the bytes representation for protobuf encoding

func (UUID) MarshalJSON 

func (uuid UUID) MarshalJSON() ([]byte, error)

MarshalJSON returns the string-representation of the UUID as a JSON-string.

func (UUID) MarshalText 

func (uuid UUID) MarshalText() ([]byte, error)

MarshalText returns the string-representation of the UUID as a byte-array.

func (UUID) MarshalTo 

func (uuid UUID) MarshalTo(data []byte) (n int, err error)

MarshalTo write the bytes representation for protobuf encoding to a buffer

func (*UUID) ReadBytes 

func (uuid *UUID) ReadBytes(str []byte) error

ReadBytes reads the supplied byte array of hexadecimal characters representing a UUID into the instance.

func (*UUID) SetString 

func (uuid *UUID) SetString(str string) error

SetString sets the uuid value from a string

func (*UUID) SetZero 

func (uuid *UUID) SetZero()

SetZero reset the uuid to zeros

func (*UUID) Size 

func (uuid *UUID) Size() int

Size returns the size needed for a protobuf encoding

func (UUID) String 

func (uuid UUID) String() string

String returns a string (hex) representation of the uuid

func (*UUID) Unmarshal 

func (uuid *UUID) Unmarshal(data []byte) error

Unmarshal loads a value from a protobuf encoding

func (*UUID) UnmarshalJSON 

func (uuid *UUID) UnmarshalJSON(data []byte) error

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 

func (uuid *UUID) UnmarshalText(data []byte) error

UnmarshalText reads an UUID from a string into the UUID instance. If this fails the state of the UUID is undetermined.

type UUIDSlice added in v3.3.0 

type UUIDSlice []UUID

UUIDSlice attaches the methods of sort.Interface to []UUID, sorting in increasing order.

func (UUIDSlice) Len added in v3.3.0 

func (s UUIDSlice) Len() int

Len ...

func (UUIDSlice) Less added in v3.3.0 

func (s UUIDSlice) Less(i, j int) bool

Less ...

func (UUIDSlice) Swap added in v3.3.0 

func (s UUIDSlice) Swap(i, j int)

Swap ...

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

func (*WhoAmIClient) WhoAmI 

func (c *WhoAmIClient) WhoAmI(identifier string) (resp Account, err error)

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

type WhoAmIServer 

type WhoAmIServer interface {
	WhoAmI(ctx context.Context, identifier string) (resp Account, err error)
}

WhoAmIServer is the interface that providers of the service WhoAmI should implement.

Source Files

View all Source files

Directories

Path Synopsis
This code was autogenerated from xbus/control.proto, do not edit.
 This code was autogenerated from xbus/control.proto, do not edit.

Jump to

Keyboard shortcuts

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