control

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: 18 Imported by: 12

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthControl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowControl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupControl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ProcessControlRequest_Command_name = map[int32]string{
	0: "NONE",
	1: "PAUSE",
	2: "RESUME",
	3: "CANCEL",
	4: "REPLAY",
}
View Source 
var ProcessControlRequest_Command_value = map[string]int32{
	"NONE":   0,
	"PAUSE":  1,
	"RESUME": 2,
	"CANCEL": 3,
	"REPLAY": 4,
}
View Source 
var StorageType_name = map[int32]string{
	0: "UNDEFINED",
	1: "ACCOUNT",
	2: "ACTOR",
	3: "ENVELOPE",
	4: "JOB",
	5: "LOG",
	6: "PASSWORD",
	7: "PIPELINE",
	8: "PROCESS",
	9: "SESSION",
}
View Source 
var StorageType_value = map[string]int32{
	"UNDEFINED": 0,
	"ACCOUNT":   1,
	"ACTOR":     2,
	"ENVELOPE":  3,
	"JOB":       4,
	"LOG":       5,
	"PASSWORD":  6,
	"PIPELINE":  7,
	"PROCESS":   8,
	"SESSION":   9,
}

Functions

This section is empty.

Types

type AccountClient 

type AccountClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewAccountClient 

func NewAccountClient(nc nrpc.NatsConn) *AccountClient

func (*AccountClient) Delete 

func (c *AccountClient) Delete(req AccountIDRequest) (err error)

func (*AccountClient) GetAPIKey 

func (c *AccountClient) GetAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)

func (*AccountClient) List 

func (c *AccountClient) List(req AccountListRequest) (resp AccountListReply, err error)

func (*AccountClient) PasswordSet 

func (c *AccountClient) PasswordSet(req AccountPasswordSetRequest) (err error)

func (*AccountClient) RenewAPIKey 

func (c *AccountClient) RenewAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)

func (*AccountClient) ResetCert 

func (c *AccountClient) ResetCert(req AccountIDRequest) (err error)

func (*AccountClient) SetAPIKey 

func (c *AccountClient) SetAPIKey(req AccountUpdateRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)

func (*AccountClient) Update 

func (c *AccountClient) Update(req AccountUpdateRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)

type AccountHandler 

type AccountHandler struct {
	// contains filtered or unexported fields
}

AccountHandler provides a NATS subscription handler that can serve a subscription using a given AccountServer implementation.

func NewAccountConcurrentHandler 

func NewAccountConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s AccountServer) *AccountHandler

func NewAccountHandler 

func NewAccountHandler(ctx context.Context, nc nrpc.NatsConn, s AccountServer) *AccountHandler

func (*AccountHandler) Handler 

func (h *AccountHandler) Handler(msg *nats.Msg)

func (*AccountHandler) SetEncodings 

func (h *AccountHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*AccountHandler) Subject 

func (h *AccountHandler) Subject() string

type AccountIDRequest 

type AccountIDRequest struct {
	AccountID            xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,opt,name=accountID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"accountID"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedAccountIDRequest 

func NewPopulatedAccountIDRequest(r randyControl, easy bool) *AccountIDRequest

func (*AccountIDRequest) Descriptor 

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

func (*AccountIDRequest) Equal 

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

func (*AccountIDRequest) GoString 

func (this *AccountIDRequest) GoString() string

func (*AccountIDRequest) Marshal 

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

func (*AccountIDRequest) MarshalTo 

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

func (*AccountIDRequest) MarshalToSizedBuffer 

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

func (*AccountIDRequest) ProtoMessage 

func (*AccountIDRequest) ProtoMessage()

func (*AccountIDRequest) Reset 

func (m *AccountIDRequest) Reset()

func (*AccountIDRequest) Size 

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

func (*AccountIDRequest) String 

func (this *AccountIDRequest) String() string

func (*AccountIDRequest) Unmarshal 

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

func (*AccountIDRequest) VerboseEqual 

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

func (*AccountIDRequest) XXX_DiscardUnknown 

func (m *AccountIDRequest) XXX_DiscardUnknown()

func (*AccountIDRequest) XXX_Marshal 

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

func (*AccountIDRequest) XXX_Merge 

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

func (*AccountIDRequest) XXX_Size 

func (m *AccountIDRequest) XXX_Size() int

func (*AccountIDRequest) XXX_Unmarshal 

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

type AccountListReply 

type AccountListReply struct {
	AccountList          []api.Account `protobuf:"bytes,1,rep,name=accountList,proto3" json:"accountList"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedAccountListReply 

func NewPopulatedAccountListReply(r randyControl, easy bool) *AccountListReply

func (*AccountListReply) Descriptor 

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

func (*AccountListReply) Equal 

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

func (*AccountListReply) GetAccountList 

func (m *AccountListReply) GetAccountList() []api.Account

func (*AccountListReply) GoString 

func (this *AccountListReply) GoString() string

func (*AccountListReply) Marshal 

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

func (*AccountListReply) MarshalTo 

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

func (*AccountListReply) MarshalToSizedBuffer 

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

func (*AccountListReply) ProtoMessage 

func (*AccountListReply) ProtoMessage()

func (*AccountListReply) Reset 

func (m *AccountListReply) Reset()

func (*AccountListReply) Size 

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

func (*AccountListReply) String 

func (this *AccountListReply) String() string

func (*AccountListReply) Unmarshal 

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

func (*AccountListReply) VerboseEqual 

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

func (*AccountListReply) XXX_DiscardUnknown 

func (m *AccountListReply) XXX_DiscardUnknown()

func (*AccountListReply) XXX_Marshal 

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

func (*AccountListReply) XXX_Merge 

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

func (*AccountListReply) XXX_Size 

func (m *AccountListReply) XXX_Size() int

func (*AccountListReply) XXX_Unmarshal 

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

type AccountListRequest 

type AccountListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedAccountListRequest 

func NewPopulatedAccountListRequest(r randyControl, easy bool) *AccountListRequest

func (*AccountListRequest) Descriptor 

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

func (*AccountListRequest) Equal 

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

func (*AccountListRequest) GoString 

func (this *AccountListRequest) GoString() string

func (*AccountListRequest) Marshal 

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

func (*AccountListRequest) MarshalTo 

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

func (*AccountListRequest) MarshalToSizedBuffer 

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

func (*AccountListRequest) ProtoMessage 

func (*AccountListRequest) ProtoMessage()

func (*AccountListRequest) Reset 

func (m *AccountListRequest) Reset()

func (*AccountListRequest) Size 

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

func (*AccountListRequest) String 

func (this *AccountListRequest) String() string

func (*AccountListRequest) Unmarshal 

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

func (*AccountListRequest) VerboseEqual 

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

func (*AccountListRequest) XXX_DiscardUnknown 

func (m *AccountListRequest) XXX_DiscardUnknown()

func (*AccountListRequest) XXX_Marshal 

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

func (*AccountListRequest) XXX_Merge 

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

func (*AccountListRequest) XXX_Size 

func (m *AccountListRequest) XXX_Size() int

func (*AccountListRequest) XXX_Unmarshal 

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

type AccountPasswordSetRequest 

type AccountPasswordSetRequest struct {
	AccountID            xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,opt,name=accountID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"accountID"`
	Password             string                      `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedAccountPasswordSetRequest 

func NewPopulatedAccountPasswordSetRequest(r randyControl, easy bool) *AccountPasswordSetRequest

func (*AccountPasswordSetRequest) Descriptor 

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

func (*AccountPasswordSetRequest) Equal 

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

func (*AccountPasswordSetRequest) GetPassword 

func (m *AccountPasswordSetRequest) GetPassword() string

func (*AccountPasswordSetRequest) GoString 

func (this *AccountPasswordSetRequest) GoString() string

func (*AccountPasswordSetRequest) Marshal 

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

func (*AccountPasswordSetRequest) MarshalTo 

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

func (*AccountPasswordSetRequest) MarshalToSizedBuffer 

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

func (*AccountPasswordSetRequest) ProtoMessage 

func (*AccountPasswordSetRequest) ProtoMessage()

func (*AccountPasswordSetRequest) Reset 

func (m *AccountPasswordSetRequest) Reset()

func (*AccountPasswordSetRequest) Size 

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

func (*AccountPasswordSetRequest) String 

func (this *AccountPasswordSetRequest) String() string

func (*AccountPasswordSetRequest) Unmarshal 

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

func (*AccountPasswordSetRequest) VerboseEqual 

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

func (*AccountPasswordSetRequest) XXX_DiscardUnknown 

func (m *AccountPasswordSetRequest) XXX_DiscardUnknown()

func (*AccountPasswordSetRequest) XXX_Marshal 

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

func (*AccountPasswordSetRequest) XXX_Merge 

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

func (*AccountPasswordSetRequest) XXX_Size 

func (m *AccountPasswordSetRequest) XXX_Size() int

func (*AccountPasswordSetRequest) XXX_Unmarshal 

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

type AccountServer 

type AccountServer interface {
	List(ctx context.Context, req AccountListRequest) (resp AccountListReply, err error)
	Update(ctx context.Context, req AccountUpdateRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)
	Delete(ctx context.Context, req AccountIDRequest) (err error)
	RenewAPIKey(ctx context.Context, req AccountIDRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)
	GetAPIKey(ctx context.Context, req AccountIDRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)
	SetAPIKey(ctx context.Context, req AccountUpdateRequest) (resp xbus_io_go_xbus_v3_api.Account, err error)
	ResetCert(ctx context.Context, req AccountIDRequest) (err error)
	PasswordSet(ctx context.Context, req AccountPasswordSetRequest) (err error)
}

AccountServer is the interface that providers of the service Account should implement.

type AccountUpdateRequest 

type AccountUpdateRequest struct {
	Account              api.Account `protobuf:"bytes,1,opt,name=account,proto3" json:"account"`
	Expire               time.Time   `protobuf:"bytes,2,opt,name=expire,proto3,stdtime" json:"expire"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedAccountUpdateRequest 

func NewPopulatedAccountUpdateRequest(r randyControl, easy bool) *AccountUpdateRequest

func (*AccountUpdateRequest) Descriptor 

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

func (*AccountUpdateRequest) Equal 

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

func (*AccountUpdateRequest) GetAccount 

func (m *AccountUpdateRequest) GetAccount() api.Account

func (*AccountUpdateRequest) GetExpire 

func (m *AccountUpdateRequest) GetExpire() time.Time

func (*AccountUpdateRequest) GoString 

func (this *AccountUpdateRequest) GoString() string

func (*AccountUpdateRequest) Marshal 

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

func (*AccountUpdateRequest) MarshalTo 

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

func (*AccountUpdateRequest) MarshalToSizedBuffer 

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

func (*AccountUpdateRequest) ProtoMessage 

func (*AccountUpdateRequest) ProtoMessage()

func (*AccountUpdateRequest) Reset 

func (m *AccountUpdateRequest) Reset()

func (*AccountUpdateRequest) Size 

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

func (*AccountUpdateRequest) String 

func (this *AccountUpdateRequest) String() string

func (*AccountUpdateRequest) Unmarshal 

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

func (*AccountUpdateRequest) VerboseEqual 

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

func (*AccountUpdateRequest) XXX_DiscardUnknown 

func (m *AccountUpdateRequest) XXX_DiscardUnknown()

func (*AccountUpdateRequest) XXX_Marshal 

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

func (*AccountUpdateRequest) XXX_Merge 

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

func (*AccountUpdateRequest) XXX_Size 

func (m *AccountUpdateRequest) XXX_Size() int

func (*AccountUpdateRequest) XXX_Unmarshal 

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

type ActorClient 

type ActorClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewActorClient 

func NewActorClient(nc nrpc.NatsConn) *ActorClient

func (*ActorClient) Create 

func (c *ActorClient) Create(req ActorRequest) (resp ActorReply, err error)

func (*ActorClient) Delete 

func (c *ActorClient) Delete(req ActorRequest) (resp ActorReply, err error)

func (*ActorClient) Query 

func (c *ActorClient) Query(req ActorRequest) (resp ActorReply, err error)

func (*ActorClient) Update 

func (c *ActorClient) Update(req ActorRequest) (resp ActorReply, err error)

type ActorHandler 

type ActorHandler struct {
	// contains filtered or unexported fields
}

ActorHandler provides a NATS subscription handler that can serve a subscription using a given ActorServer implementation.

func NewActorConcurrentHandler 

func NewActorConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ActorServer) *ActorHandler

func NewActorHandler 

func NewActorHandler(ctx context.Context, nc nrpc.NatsConn, s ActorServer) *ActorHandler

func (*ActorHandler) Handler 

func (h *ActorHandler) Handler(msg *nats.Msg)

func (*ActorHandler) SetEncodings 

func (h *ActorHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*ActorHandler) Subject 

func (h *ActorHandler) Subject() string

type ActorReply 

type ActorReply struct {
	ActorList            []api.Actor `protobuf:"bytes,1,rep,name=actorList,proto3" json:"actorList"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedActorReply 

func NewPopulatedActorReply(r randyControl, easy bool) *ActorReply

func (*ActorReply) Descriptor 

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

func (*ActorReply) Equal 

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

func (*ActorReply) GetActorList 

func (m *ActorReply) GetActorList() []api.Actor

func (*ActorReply) GoString 

func (this *ActorReply) GoString() string

func (*ActorReply) Marshal 

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

func (*ActorReply) MarshalTo 

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

func (*ActorReply) MarshalToSizedBuffer 

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

func (*ActorReply) ProtoMessage 

func (*ActorReply) ProtoMessage()

func (*ActorReply) Reset 

func (m *ActorReply) Reset()

func (*ActorReply) Size 

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

func (*ActorReply) String 

func (this *ActorReply) String() string

func (*ActorReply) Unmarshal 

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

func (*ActorReply) VerboseEqual 

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

func (*ActorReply) XXX_DiscardUnknown 

func (m *ActorReply) XXX_DiscardUnknown()

func (*ActorReply) XXX_Marshal 

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

func (*ActorReply) XXX_Merge 

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

func (*ActorReply) XXX_Size 

func (m *ActorReply) XXX_Size() int

func (*ActorReply) XXX_Unmarshal 

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

type ActorRequest 

type ActorRequest struct {
	ActorList            []api.Actor `protobuf:"bytes,1,rep,name=actorList,proto3" json:"actorList"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedActorRequest 

func NewPopulatedActorRequest(r randyControl, easy bool) *ActorRequest

func (*ActorRequest) Descriptor 

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

func (*ActorRequest) Equal 

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

func (*ActorRequest) GetActorList 

func (m *ActorRequest) GetActorList() []api.Actor

func (*ActorRequest) GoString 

func (this *ActorRequest) GoString() string

func (*ActorRequest) Marshal 

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

func (*ActorRequest) MarshalTo 

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

func (*ActorRequest) MarshalToSizedBuffer 

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

func (*ActorRequest) ProtoMessage 

func (*ActorRequest) ProtoMessage()

func (*ActorRequest) Reset 

func (m *ActorRequest) Reset()

func (*ActorRequest) Size 

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

func (*ActorRequest) String 

func (this *ActorRequest) String() string

func (*ActorRequest) Unmarshal 

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

func (*ActorRequest) VerboseEqual 

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

func (*ActorRequest) XXX_DiscardUnknown 

func (m *ActorRequest) XXX_DiscardUnknown()

func (*ActorRequest) XXX_Marshal 

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

func (*ActorRequest) XXX_Merge 

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

func (*ActorRequest) XXX_Size 

func (m *ActorRequest) XXX_Size() int

func (*ActorRequest) XXX_Unmarshal 

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

type ActorServer 

type ActorServer interface {
	Create(ctx context.Context, req ActorRequest) (resp ActorReply, err error)
	Update(ctx context.Context, req ActorRequest) (resp ActorReply, err error)
	Delete(ctx context.Context, req ActorRequest) (resp ActorReply, err error)
	Query(ctx context.Context, req ActorRequest) (resp ActorReply, err error)
}

ActorServer is the interface that providers of the service Actor should implement.

type Client 

type Client struct {
	Account   *AccountClient
	Actor     *ActorClient
	Envelope  *EnvelopeClient
	Pipeline  *PipelineClient
	Logs      *LogsClient
	PMProcess *PMProcessClient
	Process   *ProcessClient
	Debug     *DebugClient
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(nc nrpc.NatsConn) *Client

func (*Client) SetEncoding 

func (c *Client) SetEncoding(encoding string)

func (*Client) SetTimeout 

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

type DebugClient added in v3.3.1 

type DebugClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewDebugClient added in v3.3.1 

func NewDebugClient(nc nrpc.NatsConn) *DebugClient

func (*DebugClient) Info added in v3.3.1 

func (c *DebugClient) Info(
	ctx context.Context,
	req DebugInfoRequest,
	cb func(context.Context, OctetStreamList),
) error

type DebugHandler added in v3.3.1 

type DebugHandler struct {
	// contains filtered or unexported fields
}

DebugHandler provides a NATS subscription handler that can serve a subscription using a given DebugServer implementation.

func NewDebugConcurrentHandler added in v3.3.1 

func NewDebugConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s DebugServer) *DebugHandler

func NewDebugHandler added in v3.3.1 

func NewDebugHandler(ctx context.Context, nc nrpc.NatsConn, s DebugServer) *DebugHandler

func (*DebugHandler) Handler added in v3.3.1 

func (h *DebugHandler) Handler(msg *nats.Msg)

func (*DebugHandler) SetEncodings added in v3.3.1 

func (h *DebugHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*DebugHandler) Subject added in v3.3.1 

func (h *DebugHandler) Subject() string

type DebugInfoRequest added in v3.3.1 

type DebugInfoRequest struct {
	/// The debug information entry to return
	Entry string `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	/// Arguments to the info command
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	/// The output format. May not apply to all the possible entries
	Format               string   `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedDebugInfoRequest added in v3.3.1 

func NewPopulatedDebugInfoRequest(r randyControl, easy bool) *DebugInfoRequest

func (*DebugInfoRequest) Descriptor added in v3.3.1 

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

func (*DebugInfoRequest) Equal added in v3.3.1 

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

func (*DebugInfoRequest) GetArgs added in v3.3.1 

func (m *DebugInfoRequest) GetArgs() []string

func (*DebugInfoRequest) GetEntry added in v3.3.1 

func (m *DebugInfoRequest) GetEntry() string

func (*DebugInfoRequest) GetFormat added in v3.3.1 

func (m *DebugInfoRequest) GetFormat() string

func (*DebugInfoRequest) GoString added in v3.3.1 

func (this *DebugInfoRequest) GoString() string

func (*DebugInfoRequest) Marshal added in v3.3.1 

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

func (*DebugInfoRequest) MarshalTo added in v3.3.1 

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

func (*DebugInfoRequest) MarshalToSizedBuffer added in v3.3.1 

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

func (*DebugInfoRequest) ProtoMessage added in v3.3.1 

func (*DebugInfoRequest) ProtoMessage()

func (*DebugInfoRequest) Reset added in v3.3.1 

func (m *DebugInfoRequest) Reset()

func (*DebugInfoRequest) Size added in v3.3.1 

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

func (*DebugInfoRequest) String added in v3.3.1 

func (this *DebugInfoRequest) String() string

func (*DebugInfoRequest) Unmarshal added in v3.3.1 

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

func (*DebugInfoRequest) VerboseEqual added in v3.3.1 

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

func (*DebugInfoRequest) XXX_DiscardUnknown added in v3.3.1 

func (m *DebugInfoRequest) XXX_DiscardUnknown()

func (*DebugInfoRequest) XXX_Marshal added in v3.3.1 

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

func (*DebugInfoRequest) XXX_Merge added in v3.3.1 

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

func (*DebugInfoRequest) XXX_Size added in v3.3.1 

func (m *DebugInfoRequest) XXX_Size() int

func (*DebugInfoRequest) XXX_Unmarshal added in v3.3.1 

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

type DebugServer added in v3.3.1 

type DebugServer interface {
	Info(ctx context.Context, req DebugInfoRequest, pushRep func(OctetStreamList)) (err error)
}

DebugServer is the interface that providers of the service Debug should implement.

type EnvelopeClient 

type EnvelopeClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewEnvelopeClient 

func NewEnvelopeClient(nc nrpc.NatsConn) *EnvelopeClient

func (*EnvelopeClient) GetStorageStat added in v3.2.0 

func (c *EnvelopeClient) GetStorageStat() (resp StorageStat, err error)

func (*EnvelopeClient) Purge 

func (c *EnvelopeClient) Purge(
	ctx context.Context,
	cb func(context.Context, TaskProgress),
) error

type EnvelopeHandler 

type EnvelopeHandler struct {
	// contains filtered or unexported fields
}

EnvelopeHandler provides a NATS subscription handler that can serve a subscription using a given EnvelopeServer implementation.

func NewEnvelopeConcurrentHandler 

func NewEnvelopeConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s EnvelopeServer) *EnvelopeHandler

func NewEnvelopeHandler 

func NewEnvelopeHandler(ctx context.Context, nc nrpc.NatsConn, s EnvelopeServer) *EnvelopeHandler

func (*EnvelopeHandler) Handler 

func (h *EnvelopeHandler) Handler(msg *nats.Msg)

func (*EnvelopeHandler) SetEncodings 

func (h *EnvelopeHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*EnvelopeHandler) Subject 

func (h *EnvelopeHandler) Subject() string

type EnvelopeServer 

type EnvelopeServer interface {
	Purge(ctx context.Context, pushRep func(TaskProgress)) (err error)
	GetStorageStat(ctx context.Context) (resp StorageStat, err error)
}

EnvelopeServer is the interface that providers of the service Envelope should implement.

type LogsClient 

type LogsClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewLogsClient 

func NewLogsClient(nc nrpc.NatsConn) *LogsClient

func (*LogsClient) GetStorageStat added in v3.2.0 

func (c *LogsClient) GetStorageStat() (resp StorageStat, err error)

func (*LogsClient) Purge 

func (c *LogsClient) Purge(
	ctx context.Context,
	req LogsPurgeRequest,
	cb func(context.Context, LogsPurgeReply),
) error

type LogsHandler 

type LogsHandler struct {
	// contains filtered or unexported fields
}

LogsHandler provides a NATS subscription handler that can serve a subscription using a given LogsServer implementation.

func NewLogsConcurrentHandler 

func NewLogsConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s LogsServer) *LogsHandler

func NewLogsHandler 

func NewLogsHandler(ctx context.Context, nc nrpc.NatsConn, s LogsServer) *LogsHandler

func (*LogsHandler) Handler 

func (h *LogsHandler) Handler(msg *nats.Msg)

func (*LogsHandler) SetEncodings 

func (h *LogsHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*LogsHandler) Subject 

func (h *LogsHandler) Subject() string

type LogsPurgeReply 

type LogsPurgeReply struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedLogsPurgeReply 

func NewPopulatedLogsPurgeReply(r randyControl, easy bool) *LogsPurgeReply

func (*LogsPurgeReply) Descriptor 

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

func (*LogsPurgeReply) Equal 

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

func (*LogsPurgeReply) GetCount 

func (m *LogsPurgeReply) GetCount() int64

func (*LogsPurgeReply) GoString 

func (this *LogsPurgeReply) GoString() string

func (*LogsPurgeReply) Marshal 

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

func (*LogsPurgeReply) MarshalTo 

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

func (*LogsPurgeReply) MarshalToSizedBuffer 

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

func (*LogsPurgeReply) ProtoMessage 

func (*LogsPurgeReply) ProtoMessage()

func (*LogsPurgeReply) Reset 

func (m *LogsPurgeReply) Reset()

func (*LogsPurgeReply) Size 

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

func (*LogsPurgeReply) String 

func (this *LogsPurgeReply) String() string

func (*LogsPurgeReply) Unmarshal 

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

func (*LogsPurgeReply) VerboseEqual 

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

func (*LogsPurgeReply) XXX_DiscardUnknown 

func (m *LogsPurgeReply) XXX_DiscardUnknown()

func (*LogsPurgeReply) XXX_Marshal 

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

func (*LogsPurgeReply) XXX_Merge 

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

func (*LogsPurgeReply) XXX_Size 

func (m *LogsPurgeReply) XXX_Size() int

func (*LogsPurgeReply) XXX_Unmarshal 

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

type LogsPurgeRequest 

type LogsPurgeRequest struct {
	Before               time.Time `protobuf:"bytes,1,opt,name=before,proto3,stdtime" json:"before"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func NewPopulatedLogsPurgeRequest 

func NewPopulatedLogsPurgeRequest(r randyControl, easy bool) *LogsPurgeRequest

func (*LogsPurgeRequest) Descriptor 

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

func (*LogsPurgeRequest) Equal 

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

func (*LogsPurgeRequest) GetBefore 

func (m *LogsPurgeRequest) GetBefore() time.Time

func (*LogsPurgeRequest) GoString 

func (this *LogsPurgeRequest) GoString() string

func (*LogsPurgeRequest) Marshal 

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

func (*LogsPurgeRequest) MarshalTo 

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

func (*LogsPurgeRequest) MarshalToSizedBuffer 

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

func (*LogsPurgeRequest) ProtoMessage 

func (*LogsPurgeRequest) ProtoMessage()

func (*LogsPurgeRequest) Reset 

func (m *LogsPurgeRequest) Reset()

func (*LogsPurgeRequest) Size 

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

func (*LogsPurgeRequest) String 

func (this *LogsPurgeRequest) String() string

func (*LogsPurgeRequest) Unmarshal 

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

func (*LogsPurgeRequest) VerboseEqual 

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

func (*LogsPurgeRequest) XXX_DiscardUnknown 

func (m *LogsPurgeRequest) XXX_DiscardUnknown()

func (*LogsPurgeRequest) XXX_Marshal 

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

func (*LogsPurgeRequest) XXX_Merge 

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

func (*LogsPurgeRequest) XXX_Size 

func (m *LogsPurgeRequest) XXX_Size() int

func (*LogsPurgeRequest) XXX_Unmarshal 

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

type LogsServer 

type LogsServer interface {
	Purge(ctx context.Context, req LogsPurgeRequest, pushRep func(LogsPurgeReply)) (err error)
	GetStorageStat(ctx context.Context) (resp StorageStat, err error)
}

LogsServer is the interface that providers of the service Logs should implement.

type OctetStreamList 

type OctetStreamList struct {
	Chunks               []OctetStreamList_Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks"`
	Progression          int64                   `protobuf:"varint,2,opt,name=progression,proto3" json:"progression,omitempty"`
	MaxProgression       int64                   `protobuf:"varint,3,opt,name=maxProgression,proto3" json:"maxProgression,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func NewPopulatedOctetStreamList 

func NewPopulatedOctetStreamList(r randyControl, easy bool) *OctetStreamList

func (*OctetStreamList) Descriptor 

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

func (*OctetStreamList) Equal 

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

func (*OctetStreamList) GetChunks 

func (m *OctetStreamList) GetChunks() []OctetStreamList_Chunk

func (*OctetStreamList) GetMaxProgression 

func (m *OctetStreamList) GetMaxProgression() int64

func (*OctetStreamList) GetProgression 

func (m *OctetStreamList) GetProgression() int64

func (*OctetStreamList) GoString 

func (this *OctetStreamList) GoString() string

func (*OctetStreamList) Marshal 

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

func (*OctetStreamList) MarshalTo 

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

func (*OctetStreamList) MarshalToSizedBuffer 

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

func (*OctetStreamList) ProtoMessage 

func (*OctetStreamList) ProtoMessage()

func (*OctetStreamList) Reset 

func (m *OctetStreamList) Reset()

func (*OctetStreamList) Size 

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

func (*OctetStreamList) String 

func (this *OctetStreamList) String() string

func (*OctetStreamList) Unmarshal 

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

func (*OctetStreamList) VerboseEqual 

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

func (*OctetStreamList) XXX_DiscardUnknown 

func (m *OctetStreamList) XXX_DiscardUnknown()

func (*OctetStreamList) XXX_Marshal 

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

func (*OctetStreamList) XXX_Merge 

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

func (*OctetStreamList) XXX_Size 

func (m *OctetStreamList) XXX_Size() int

func (*OctetStreamList) XXX_Unmarshal 

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

type OctetStreamList_Chunk 

type OctetStreamList_Chunk struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Index                int64    `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedOctetStreamList_Chunk 

func NewPopulatedOctetStreamList_Chunk(r randyControl, easy bool) *OctetStreamList_Chunk

func (*OctetStreamList_Chunk) Descriptor 

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

func (*OctetStreamList_Chunk) Equal 

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

func (*OctetStreamList_Chunk) GetData 

func (m *OctetStreamList_Chunk) GetData() []byte

func (*OctetStreamList_Chunk) GetIndex 

func (m *OctetStreamList_Chunk) GetIndex() int64

func (*OctetStreamList_Chunk) GoString 

func (this *OctetStreamList_Chunk) GoString() string

func (*OctetStreamList_Chunk) Marshal 

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

func (*OctetStreamList_Chunk) MarshalTo 

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

func (*OctetStreamList_Chunk) MarshalToSizedBuffer 

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

func (*OctetStreamList_Chunk) ProtoMessage 

func (*OctetStreamList_Chunk) ProtoMessage()

func (*OctetStreamList_Chunk) Reset 

func (m *OctetStreamList_Chunk) Reset()

func (*OctetStreamList_Chunk) Size 

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

func (*OctetStreamList_Chunk) String 

func (this *OctetStreamList_Chunk) String() string

func (*OctetStreamList_Chunk) Unmarshal 

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

func (*OctetStreamList_Chunk) VerboseEqual 

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

func (*OctetStreamList_Chunk) XXX_DiscardUnknown 

func (m *OctetStreamList_Chunk) XXX_DiscardUnknown()

func (*OctetStreamList_Chunk) XXX_Marshal 

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

func (*OctetStreamList_Chunk) XXX_Merge 

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

func (*OctetStreamList_Chunk) XXX_Size 

func (m *OctetStreamList_Chunk) XXX_Size() int

func (*OctetStreamList_Chunk) XXX_Unmarshal 

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

type PMProcessClient 

type PMProcessClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewPMProcessClient 

func NewPMProcessClient(nc nrpc.NatsConn) *PMProcessClient

func (*PMProcessClient) Query 

func (c *PMProcessClient) Query(
	ctx context.Context,
	req PMProcessQueryRequest,
	cb func(context.Context, PMProcessQueryReply),
) error

func (*PMProcessClient) SetStatus 

func (c *PMProcessClient) SetStatus(req PMProcessSetStatusRequest) (err error)

type PMProcessHandler 

type PMProcessHandler struct {
	// contains filtered or unexported fields
}

PMProcessHandler provides a NATS subscription handler that can serve a subscription using a given PMProcessServer implementation.

func NewPMProcessConcurrentHandler 

func NewPMProcessConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s PMProcessServer) *PMProcessHandler

func NewPMProcessHandler 

func NewPMProcessHandler(ctx context.Context, nc nrpc.NatsConn, s PMProcessServer) *PMProcessHandler

func (*PMProcessHandler) Handler 

func (h *PMProcessHandler) Handler(msg *nats.Msg)

func (*PMProcessHandler) SetEncodings 

func (h *PMProcessHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*PMProcessHandler) Subject 

func (h *PMProcessHandler) Subject() string

type PMProcessQueryReply 

type PMProcessQueryReply struct {
	PMProcessList        []api.PMProcess `protobuf:"bytes,1,rep,name=pMProcessList,proto3" json:"pMProcessList"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedPMProcessQueryReply 

func NewPopulatedPMProcessQueryReply(r randyControl, easy bool) *PMProcessQueryReply

func (*PMProcessQueryReply) Descriptor 

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

func (*PMProcessQueryReply) Equal 

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

func (*PMProcessQueryReply) GetPMProcessList 

func (m *PMProcessQueryReply) GetPMProcessList() []api.PMProcess

func (*PMProcessQueryReply) GoString 

func (this *PMProcessQueryReply) GoString() string

func (*PMProcessQueryReply) Marshal 

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

func (*PMProcessQueryReply) MarshalTo 

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

func (*PMProcessQueryReply) MarshalToSizedBuffer 

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

func (*PMProcessQueryReply) ProtoMessage 

func (*PMProcessQueryReply) ProtoMessage()

func (*PMProcessQueryReply) Reset 

func (m *PMProcessQueryReply) Reset()

func (*PMProcessQueryReply) Size 

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

func (*PMProcessQueryReply) String 

func (this *PMProcessQueryReply) String() string

func (*PMProcessQueryReply) Unmarshal 

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

func (*PMProcessQueryReply) VerboseEqual 

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

func (*PMProcessQueryReply) XXX_DiscardUnknown 

func (m *PMProcessQueryReply) XXX_DiscardUnknown()

func (*PMProcessQueryReply) XXX_Marshal 

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

func (*PMProcessQueryReply) XXX_Merge 

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

func (*PMProcessQueryReply) XXX_Size 

func (m *PMProcessQueryReply) XXX_Size() int

func (*PMProcessQueryReply) XXX_Unmarshal 

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

type PMProcessQueryRequest 

type PMProcessQueryRequest struct {
	Level                api.LogLevel                  `protobuf:"varint,1,opt,name=level,proto3,enum=xbus.LogLevel" json:"level,omitempty"`
	IncludeClosed        bool                          `protobuf:"varint,2,opt,name=includeClosed,proto3" json:"includeClosed,omitempty"`
	ProcessIDs           []xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,3,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"processIDs"`
	ReturnLogs           bool                          `protobuf:"varint,4,opt,name=returnLogs,proto3" json:"returnLogs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func NewPopulatedPMProcessQueryRequest 

func NewPopulatedPMProcessQueryRequest(r randyControl, easy bool) *PMProcessQueryRequest

func (*PMProcessQueryRequest) Descriptor 

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

func (*PMProcessQueryRequest) Equal 

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

func (*PMProcessQueryRequest) GetIncludeClosed 

func (m *PMProcessQueryRequest) GetIncludeClosed() bool

func (*PMProcessQueryRequest) GetLevel 

func (m *PMProcessQueryRequest) GetLevel() api.LogLevel

func (*PMProcessQueryRequest) GetReturnLogs 

func (m *PMProcessQueryRequest) GetReturnLogs() bool

func (*PMProcessQueryRequest) GoString 

func (this *PMProcessQueryRequest) GoString() string

func (*PMProcessQueryRequest) Marshal 

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

func (*PMProcessQueryRequest) MarshalTo 

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

func (*PMProcessQueryRequest) MarshalToSizedBuffer 

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

func (*PMProcessQueryRequest) ProtoMessage 

func (*PMProcessQueryRequest) ProtoMessage()

func (*PMProcessQueryRequest) Reset 

func (m *PMProcessQueryRequest) Reset()

func (*PMProcessQueryRequest) Size 

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

func (*PMProcessQueryRequest) String 

func (this *PMProcessQueryRequest) String() string

func (*PMProcessQueryRequest) Unmarshal 

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

func (*PMProcessQueryRequest) VerboseEqual 

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

func (*PMProcessQueryRequest) XXX_DiscardUnknown 

func (m *PMProcessQueryRequest) XXX_DiscardUnknown()

func (*PMProcessQueryRequest) XXX_Marshal 

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

func (*PMProcessQueryRequest) XXX_Merge 

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

func (*PMProcessQueryRequest) XXX_Size 

func (m *PMProcessQueryRequest) XXX_Size() int

func (*PMProcessQueryRequest) XXX_Unmarshal 

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

type PMProcessServer 

type PMProcessServer interface {
	Query(ctx context.Context, req PMProcessQueryRequest, pushRep func(PMProcessQueryReply)) (err error)
	SetStatus(ctx context.Context, req PMProcessSetStatusRequest) (err error)
}

PMProcessServer is the interface that providers of the service PMProcess should implement.

type PMProcessSetStatusRequest 

type PMProcessSetStatusRequest struct {
	ProcessID            xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"processID"`
	Status               api.PMProcess_Status        `protobuf:"varint,2,opt,name=status,proto3,enum=xbus.PMProcess_Status" json:"status,omitempty"`
	Comment              string                      `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedPMProcessSetStatusRequest 

func NewPopulatedPMProcessSetStatusRequest(r randyControl, easy bool) *PMProcessSetStatusRequest

func (*PMProcessSetStatusRequest) Descriptor 

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

func (*PMProcessSetStatusRequest) Equal 

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

func (*PMProcessSetStatusRequest) GetComment 

func (m *PMProcessSetStatusRequest) GetComment() string

func (*PMProcessSetStatusRequest) GetStatus 

func (m *PMProcessSetStatusRequest) GetStatus() api.PMProcess_Status

func (*PMProcessSetStatusRequest) GoString 

func (this *PMProcessSetStatusRequest) GoString() string

func (*PMProcessSetStatusRequest) Marshal 

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

func (*PMProcessSetStatusRequest) MarshalTo 

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

func (*PMProcessSetStatusRequest) MarshalToSizedBuffer 

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

func (*PMProcessSetStatusRequest) ProtoMessage 

func (*PMProcessSetStatusRequest) ProtoMessage()

func (*PMProcessSetStatusRequest) Reset 

func (m *PMProcessSetStatusRequest) Reset()

func (*PMProcessSetStatusRequest) Size 

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

func (*PMProcessSetStatusRequest) String 

func (this *PMProcessSetStatusRequest) String() string

func (*PMProcessSetStatusRequest) Unmarshal 

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

func (*PMProcessSetStatusRequest) VerboseEqual 

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

func (*PMProcessSetStatusRequest) XXX_DiscardUnknown 

func (m *PMProcessSetStatusRequest) XXX_DiscardUnknown()

func (*PMProcessSetStatusRequest) XXX_Marshal 

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

func (*PMProcessSetStatusRequest) XXX_Merge 

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

func (*PMProcessSetStatusRequest) XXX_Size 

func (m *PMProcessSetStatusRequest) XXX_Size() int

func (*PMProcessSetStatusRequest) XXX_Unmarshal 

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

type PipelineClient 

type PipelineClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewPipelineClient 

func NewPipelineClient(nc nrpc.NatsConn) *PipelineClient

func (*PipelineClient) GetGraph 

func (c *PipelineClient) GetGraph(req xbus_io_go_xbus_v3_api.PipelineInfo) (resp xbus_io_go_xbus_v3_api.StringReply, err error)

func (*PipelineClient) Query 

func (c *PipelineClient) Query(req PipelineQueryRequest) (resp PipelineQueryReply, err error)

func (*PipelineClient) Save 

func (c *PipelineClient) Save(req PipelineSaveRequest) (resp PipelineSaveReply, err error)

func (*PipelineClient) SetStatus 

func (c *PipelineClient) SetStatus(req xbus_io_go_xbus_v3_api.PipelineInfo) (resp PipelineSetStatusReply, err error)

type PipelineHandler 

type PipelineHandler struct {
	// contains filtered or unexported fields
}

PipelineHandler provides a NATS subscription handler that can serve a subscription using a given PipelineServer implementation.

func NewPipelineConcurrentHandler 

func NewPipelineConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s PipelineServer) *PipelineHandler

func NewPipelineHandler 

func NewPipelineHandler(ctx context.Context, nc nrpc.NatsConn, s PipelineServer) *PipelineHandler

func (*PipelineHandler) Handler 

func (h *PipelineHandler) Handler(msg *nats.Msg)

func (*PipelineHandler) SetEncodings 

func (h *PipelineHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*PipelineHandler) Subject 

func (h *PipelineHandler) Subject() string

type PipelineQueryReply 

type PipelineQueryReply struct {
	PipelineList         []api.PipelineInfo `protobuf:"bytes,1,rep,name=pipelineList,proto3" json:"pipelineList"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func NewPopulatedPipelineQueryReply 

func NewPopulatedPipelineQueryReply(r randyControl, easy bool) *PipelineQueryReply

func (*PipelineQueryReply) Descriptor 

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

func (*PipelineQueryReply) Equal 

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

func (*PipelineQueryReply) GetPipelineList 

func (m *PipelineQueryReply) GetPipelineList() []api.PipelineInfo

func (*PipelineQueryReply) GoString 

func (this *PipelineQueryReply) GoString() string

func (*PipelineQueryReply) Marshal 

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

func (*PipelineQueryReply) MarshalTo 

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

func (*PipelineQueryReply) MarshalToSizedBuffer 

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

func (*PipelineQueryReply) ProtoMessage 

func (*PipelineQueryReply) ProtoMessage()

func (*PipelineQueryReply) Reset 

func (m *PipelineQueryReply) Reset()

func (*PipelineQueryReply) Size 

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

func (*PipelineQueryReply) String 

func (this *PipelineQueryReply) String() string

func (*PipelineQueryReply) Unmarshal 

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

func (*PipelineQueryReply) VerboseEqual 

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

func (*PipelineQueryReply) XXX_DiscardUnknown 

func (m *PipelineQueryReply) XXX_DiscardUnknown()

func (*PipelineQueryReply) XXX_Marshal 

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

func (*PipelineQueryReply) XXX_Merge 

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

func (*PipelineQueryReply) XXX_Size 

func (m *PipelineQueryReply) XXX_Size() int

func (*PipelineQueryReply) XXX_Unmarshal 

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

type PipelineQueryRequest 

type PipelineQueryRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedPipelineQueryRequest 

func NewPopulatedPipelineQueryRequest(r randyControl, easy bool) *PipelineQueryRequest

func (*PipelineQueryRequest) Descriptor 

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

func (*PipelineQueryRequest) Equal 

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

func (*PipelineQueryRequest) GetName 

func (m *PipelineQueryRequest) GetName() string

func (*PipelineQueryRequest) GoString 

func (this *PipelineQueryRequest) GoString() string

func (*PipelineQueryRequest) Marshal 

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

func (*PipelineQueryRequest) MarshalTo 

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

func (*PipelineQueryRequest) MarshalToSizedBuffer 

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

func (*PipelineQueryRequest) ProtoMessage 

func (*PipelineQueryRequest) ProtoMessage()

func (*PipelineQueryRequest) Reset 

func (m *PipelineQueryRequest) Reset()

func (*PipelineQueryRequest) Size 

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

func (*PipelineQueryRequest) String 

func (this *PipelineQueryRequest) String() string

func (*PipelineQueryRequest) Unmarshal 

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

func (*PipelineQueryRequest) VerboseEqual 

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

func (*PipelineQueryRequest) XXX_DiscardUnknown 

func (m *PipelineQueryRequest) XXX_DiscardUnknown()

func (*PipelineQueryRequest) XXX_Marshal 

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

func (*PipelineQueryRequest) XXX_Merge 

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

func (*PipelineQueryRequest) XXX_Size 

func (m *PipelineQueryRequest) XXX_Size() int

func (*PipelineQueryRequest) XXX_Unmarshal 

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

type PipelineSaveReply 

type PipelineSaveReply struct {
	Info                 api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"`
	Graph                string           `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	IsValid              bool             `protobuf:"varint,3,opt,name=isValid,proto3" json:"isValid,omitempty"`
	ValidationMessages   []string         `protobuf:"bytes,4,rep,name=validationMessages,proto3" json:"validationMessages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedPipelineSaveReply 

func NewPopulatedPipelineSaveReply(r randyControl, easy bool) *PipelineSaveReply

func (*PipelineSaveReply) Descriptor 

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

func (*PipelineSaveReply) Equal 

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

func (*PipelineSaveReply) GetGraph 

func (m *PipelineSaveReply) GetGraph() string

func (*PipelineSaveReply) GetInfo 

func (m *PipelineSaveReply) GetInfo() api.PipelineInfo

func (*PipelineSaveReply) GetIsValid 

func (m *PipelineSaveReply) GetIsValid() bool

func (*PipelineSaveReply) GetValidationMessages 

func (m *PipelineSaveReply) GetValidationMessages() []string

func (*PipelineSaveReply) GoString 

func (this *PipelineSaveReply) GoString() string

func (*PipelineSaveReply) Marshal 

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

func (*PipelineSaveReply) MarshalTo 

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

func (*PipelineSaveReply) MarshalToSizedBuffer 

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

func (*PipelineSaveReply) ProtoMessage 

func (*PipelineSaveReply) ProtoMessage()

func (*PipelineSaveReply) Reset 

func (m *PipelineSaveReply) Reset()

func (*PipelineSaveReply) Size 

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

func (*PipelineSaveReply) String 

func (this *PipelineSaveReply) String() string

func (*PipelineSaveReply) Unmarshal 

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

func (*PipelineSaveReply) VerboseEqual 

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

func (*PipelineSaveReply) XXX_DiscardUnknown 

func (m *PipelineSaveReply) XXX_DiscardUnknown()

func (*PipelineSaveReply) XXX_Marshal 

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

func (*PipelineSaveReply) XXX_Merge 

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

func (*PipelineSaveReply) XXX_Size 

func (m *PipelineSaveReply) XXX_Size() int

func (*PipelineSaveReply) XXX_Unmarshal 

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

type PipelineSaveRequest 

type PipelineSaveRequest struct {
	Info                 api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"`
	Graph                string           `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedPipelineSaveRequest 

func NewPopulatedPipelineSaveRequest(r randyControl, easy bool) *PipelineSaveRequest

func (*PipelineSaveRequest) Descriptor 

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

func (*PipelineSaveRequest) Equal 

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

func (*PipelineSaveRequest) GetGraph 

func (m *PipelineSaveRequest) GetGraph() string

func (*PipelineSaveRequest) GetInfo 

func (m *PipelineSaveRequest) GetInfo() api.PipelineInfo

func (*PipelineSaveRequest) GoString 

func (this *PipelineSaveRequest) GoString() string

func (*PipelineSaveRequest) Marshal 

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

func (*PipelineSaveRequest) MarshalTo 

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

func (*PipelineSaveRequest) MarshalToSizedBuffer 

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

func (*PipelineSaveRequest) ProtoMessage 

func (*PipelineSaveRequest) ProtoMessage()

func (*PipelineSaveRequest) Reset 

func (m *PipelineSaveRequest) Reset()

func (*PipelineSaveRequest) Size 

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

func (*PipelineSaveRequest) String 

func (this *PipelineSaveRequest) String() string

func (*PipelineSaveRequest) Unmarshal 

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

func (*PipelineSaveRequest) VerboseEqual 

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

func (*PipelineSaveRequest) XXX_DiscardUnknown 

func (m *PipelineSaveRequest) XXX_DiscardUnknown()

func (*PipelineSaveRequest) XXX_Marshal 

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

func (*PipelineSaveRequest) XXX_Merge 

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

func (*PipelineSaveRequest) XXX_Size 

func (m *PipelineSaveRequest) XXX_Size() int

func (*PipelineSaveRequest) XXX_Unmarshal 

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

type PipelineServer 

type PipelineServer interface {
	Query(ctx context.Context, req PipelineQueryRequest) (resp PipelineQueryReply, err error)
	Save(ctx context.Context, req PipelineSaveRequest) (resp PipelineSaveReply, err error)
	SetStatus(ctx context.Context, req xbus_io_go_xbus_v3_api.PipelineInfo) (resp PipelineSetStatusReply, err error)
	GetGraph(ctx context.Context, req xbus_io_go_xbus_v3_api.PipelineInfo) (resp xbus_io_go_xbus_v3_api.StringReply, err error)
}

PipelineServer is the interface that providers of the service Pipeline should implement.

type PipelineSetStatusReply 

type PipelineSetStatusReply struct {
	Info                 api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"`
	IsValid              bool             `protobuf:"varint,2,opt,name=isValid,proto3" json:"isValid,omitempty"`
	ValidationMessages   []string         `protobuf:"bytes,4,rep,name=validationMessages,proto3" json:"validationMessages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedPipelineSetStatusReply 

func NewPopulatedPipelineSetStatusReply(r randyControl, easy bool) *PipelineSetStatusReply

func (*PipelineSetStatusReply) Descriptor 

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

func (*PipelineSetStatusReply) Equal 

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

func (*PipelineSetStatusReply) GetInfo 

func (m *PipelineSetStatusReply) GetInfo() api.PipelineInfo

func (*PipelineSetStatusReply) GetIsValid 

func (m *PipelineSetStatusReply) GetIsValid() bool

func (*PipelineSetStatusReply) GetValidationMessages 

func (m *PipelineSetStatusReply) GetValidationMessages() []string

func (*PipelineSetStatusReply) GoString 

func (this *PipelineSetStatusReply) GoString() string

func (*PipelineSetStatusReply) Marshal 

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

func (*PipelineSetStatusReply) MarshalTo 

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

func (*PipelineSetStatusReply) MarshalToSizedBuffer 

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

func (*PipelineSetStatusReply) ProtoMessage 

func (*PipelineSetStatusReply) ProtoMessage()

func (*PipelineSetStatusReply) Reset 

func (m *PipelineSetStatusReply) Reset()

func (*PipelineSetStatusReply) Size 

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

func (*PipelineSetStatusReply) String 

func (this *PipelineSetStatusReply) String() string

func (*PipelineSetStatusReply) Unmarshal 

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

func (*PipelineSetStatusReply) VerboseEqual 

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

func (*PipelineSetStatusReply) XXX_DiscardUnknown 

func (m *PipelineSetStatusReply) XXX_DiscardUnknown()

func (*PipelineSetStatusReply) XXX_Marshal 

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

func (*PipelineSetStatusReply) XXX_Merge 

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

func (*PipelineSetStatusReply) XXX_Size 

func (m *PipelineSetStatusReply) XXX_Size() int

func (*PipelineSetStatusReply) XXX_Unmarshal 

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

type ProcessClient 

type ProcessClient struct {
	PkgSubject string
	Subject    string
	Encoding   string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewProcessClient 

func NewProcessClient(nc nrpc.NatsConn) *ProcessClient

func (*ProcessClient) Control 

func (c *ProcessClient) Control(req ProcessControlRequest) (err error)

func (*ProcessClient) Export 

func (c *ProcessClient) Export(req ProcessExportRequest) (resp ProcessExportReply, err error)

func (*ProcessClient) ExportStream 

func (c *ProcessClient) ExportStream(
	ctx context.Context,
	req ProcessExportRequest,
	cb func(context.Context, OctetStreamList),
) error

func (*ProcessClient) Purge 

func (c *ProcessClient) Purge(
	ctx context.Context,
	req ProcessPurgeRequest,
	cb func(context.Context, TaskProgress),
) error

func (*ProcessClient) Query 

func (c *ProcessClient) Query(
	ctx context.Context,
	req ProcessQueryRequest,
	cb func(context.Context, ProcessQueryReply),
) error

func (*ProcessClient) QuerySummary added in v3.2.0 

func (c *ProcessClient) QuerySummary(
	ctx context.Context,
	req ProcessQueryRequest,
	cb func(context.Context, ProcessSummary),
) error

func (*ProcessClient) Replay added in v3.2.0 

func (c *ProcessClient) Replay(req ProcessReplayRequest) (resp xbus_io_go_xbus_v3_api.Process, err error)

type ProcessControlRequest 

type ProcessControlRequest struct {
	ProcessID            xbus_io_go_xbus_v3_api.UUID   `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"processID"`
	Command              ProcessControlRequest_Command `protobuf:"varint,2,opt,name=command,proto3,enum=xbus.control.ProcessControlRequest_Command" json:"command,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func NewPopulatedProcessControlRequest 

func NewPopulatedProcessControlRequest(r randyControl, easy bool) *ProcessControlRequest

func (*ProcessControlRequest) Descriptor 

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

func (*ProcessControlRequest) Equal 

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

func (*ProcessControlRequest) GetCommand 

func (m *ProcessControlRequest) GetCommand() ProcessControlRequest_Command

func (*ProcessControlRequest) GoString 

func (this *ProcessControlRequest) GoString() string

func (*ProcessControlRequest) Marshal 

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

func (*ProcessControlRequest) MarshalTo 

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

func (*ProcessControlRequest) MarshalToSizedBuffer 

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

func (*ProcessControlRequest) ProtoMessage 

func (*ProcessControlRequest) ProtoMessage()

func (*ProcessControlRequest) Reset 

func (m *ProcessControlRequest) Reset()

func (*ProcessControlRequest) Size 

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

func (*ProcessControlRequest) String 

func (this *ProcessControlRequest) String() string

func (*ProcessControlRequest) Unmarshal 

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

func (*ProcessControlRequest) VerboseEqual 

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

func (*ProcessControlRequest) XXX_DiscardUnknown 

func (m *ProcessControlRequest) XXX_DiscardUnknown()

func (*ProcessControlRequest) XXX_Marshal 

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

func (*ProcessControlRequest) XXX_Merge 

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

func (*ProcessControlRequest) XXX_Size 

func (m *ProcessControlRequest) XXX_Size() int

func (*ProcessControlRequest) XXX_Unmarshal 

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

type ProcessControlRequest_Command 

type ProcessControlRequest_Command int32
const (
	ProcessControlRequest_NONE   ProcessControlRequest_Command = 0
	ProcessControlRequest_PAUSE  ProcessControlRequest_Command = 1
	ProcessControlRequest_RESUME ProcessControlRequest_Command = 2
	ProcessControlRequest_CANCEL ProcessControlRequest_Command = 3
	ProcessControlRequest_REPLAY ProcessControlRequest_Command = 4
)

func (ProcessControlRequest_Command) EnumDescriptor 

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

func (ProcessControlRequest_Command) String 

func (x ProcessControlRequest_Command) String() string

type ProcessExportReply 

type ProcessExportReply struct {
	ProcessList          []string `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedProcessExportReply 

func NewPopulatedProcessExportReply(r randyControl, easy bool) *ProcessExportReply

func (*ProcessExportReply) Descriptor 

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

func (*ProcessExportReply) Equal 

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

func (*ProcessExportReply) GetProcessList 

func (m *ProcessExportReply) GetProcessList() []string

func (*ProcessExportReply) GoString 

func (this *ProcessExportReply) GoString() string

func (*ProcessExportReply) Marshal 

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

func (*ProcessExportReply) MarshalTo 

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

func (*ProcessExportReply) MarshalToSizedBuffer 

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

func (*ProcessExportReply) ProtoMessage 

func (*ProcessExportReply) ProtoMessage()

func (*ProcessExportReply) Reset 

func (m *ProcessExportReply) Reset()

func (*ProcessExportReply) Size 

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

func (*ProcessExportReply) String 

func (this *ProcessExportReply) String() string

func (*ProcessExportReply) Unmarshal 

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

func (*ProcessExportReply) VerboseEqual 

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

func (*ProcessExportReply) XXX_DiscardUnknown 

func (m *ProcessExportReply) XXX_DiscardUnknown()

func (*ProcessExportReply) XXX_Marshal 

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

func (*ProcessExportReply) XXX_Merge 

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

func (*ProcessExportReply) XXX_Size 

func (m *ProcessExportReply) XXX_Size() int

func (*ProcessExportReply) XXX_Unmarshal 

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

type ProcessExportRequest 

type ProcessExportRequest struct {
	ProcessIDs           []xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"processIDs"`
	ExportEnvelope       bool                          `protobuf:"varint,2,opt,name=exportEnvelope,proto3" json:"exportEnvelope,omitempty"`
	ExportJobs           bool                          `protobuf:"varint,8,opt,name=exportJobs,proto3" json:"exportJobs,omitempty"`
	ExportLogs           bool                          `protobuf:"varint,4,opt,name=exportLogs,proto3" json:"exportLogs,omitempty"`
	ExportProcessLogs    bool                          `protobuf:"varint,5,opt,name=exportProcessLogs,proto3" json:"exportProcessLogs,omitempty"`
	EnvelopeSizeLimit    int64                         `protobuf:"varint,3,opt,name=envelopeSizeLimit,proto3" json:"envelopeSizeLimit,omitempty"`
	LogLevel             api.LogLevel                  `protobuf:"varint,6,opt,name=logLevel,proto3,enum=xbus.LogLevel" json:"logLevel,omitempty"`
	ExportFull           bool                          `protobuf:"varint,7,opt,name=exportFull,proto3" json:"exportFull,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func NewPopulatedProcessExportRequest 

func NewPopulatedProcessExportRequest(r randyControl, easy bool) *ProcessExportRequest

func (*ProcessExportRequest) Descriptor 

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

func (*ProcessExportRequest) Equal 

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

func (*ProcessExportRequest) GetEnvelopeSizeLimit 

func (m *ProcessExportRequest) GetEnvelopeSizeLimit() int64

func (*ProcessExportRequest) GetExportEnvelope 

func (m *ProcessExportRequest) GetExportEnvelope() bool

func (*ProcessExportRequest) GetExportFull 

func (m *ProcessExportRequest) GetExportFull() bool

func (*ProcessExportRequest) GetExportJobs 

func (m *ProcessExportRequest) GetExportJobs() bool

func (*ProcessExportRequest) GetExportLogs 

func (m *ProcessExportRequest) GetExportLogs() bool

func (*ProcessExportRequest) GetExportProcessLogs 

func (m *ProcessExportRequest) GetExportProcessLogs() bool

func (*ProcessExportRequest) GetLogLevel 

func (m *ProcessExportRequest) GetLogLevel() api.LogLevel

func (*ProcessExportRequest) GoString 

func (this *ProcessExportRequest) GoString() string

func (*ProcessExportRequest) Marshal 

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

func (*ProcessExportRequest) MarshalTo 

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

func (*ProcessExportRequest) MarshalToSizedBuffer 

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

func (*ProcessExportRequest) ProtoMessage 

func (*ProcessExportRequest) ProtoMessage()

func (*ProcessExportRequest) Reset 

func (m *ProcessExportRequest) Reset()

func (*ProcessExportRequest) Size 

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

func (*ProcessExportRequest) String 

func (this *ProcessExportRequest) String() string

func (*ProcessExportRequest) Unmarshal 

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

func (*ProcessExportRequest) VerboseEqual 

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

func (*ProcessExportRequest) XXX_DiscardUnknown 

func (m *ProcessExportRequest) XXX_DiscardUnknown()

func (*ProcessExportRequest) XXX_Marshal 

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

func (*ProcessExportRequest) XXX_Merge 

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

func (*ProcessExportRequest) XXX_Size 

func (m *ProcessExportRequest) XXX_Size() int

func (*ProcessExportRequest) XXX_Unmarshal 

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

type ProcessHandler 

type ProcessHandler struct {
	// contains filtered or unexported fields
}

ProcessHandler provides a NATS subscription handler that can serve a subscription using a given ProcessServer implementation.

func NewProcessConcurrentHandler 

func NewProcessConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ProcessServer) *ProcessHandler

func NewProcessHandler 

func NewProcessHandler(ctx context.Context, nc nrpc.NatsConn, s ProcessServer) *ProcessHandler

func (*ProcessHandler) Handler 

func (h *ProcessHandler) Handler(msg *nats.Msg)

func (*ProcessHandler) SetEncodings 

func (h *ProcessHandler) SetEncodings(encodings []string)

SetEncodings sets the output encodings when using a '*Publish' function

func (*ProcessHandler) Subject 

func (h *ProcessHandler) Subject() string

type ProcessPurgeRequest 

type ProcessPurgeRequest struct {
	ProcessIDs           []xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"processIDs"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func NewPopulatedProcessPurgeRequest 

func NewPopulatedProcessPurgeRequest(r randyControl, easy bool) *ProcessPurgeRequest

func (*ProcessPurgeRequest) Descriptor 

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

func (*ProcessPurgeRequest) Equal 

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

func (*ProcessPurgeRequest) GoString 

func (this *ProcessPurgeRequest) GoString() string

func (*ProcessPurgeRequest) Marshal 

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

func (*ProcessPurgeRequest) MarshalTo 

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

func (*ProcessPurgeRequest) MarshalToSizedBuffer 

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

func (*ProcessPurgeRequest) ProtoMessage 

func (*ProcessPurgeRequest) ProtoMessage()

func (*ProcessPurgeRequest) Reset 

func (m *ProcessPurgeRequest) Reset()

func (*ProcessPurgeRequest) Size 

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

func (*ProcessPurgeRequest) String 

func (this *ProcessPurgeRequest) String() string

func (*ProcessPurgeRequest) Unmarshal 

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

func (*ProcessPurgeRequest) VerboseEqual 

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

func (*ProcessPurgeRequest) XXX_DiscardUnknown 

func (m *ProcessPurgeRequest) XXX_DiscardUnknown()

func (*ProcessPurgeRequest) XXX_Marshal 

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

func (*ProcessPurgeRequest) XXX_Merge 

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

func (*ProcessPurgeRequest) XXX_Size 

func (m *ProcessPurgeRequest) XXX_Size() int

func (*ProcessPurgeRequest) XXX_Unmarshal 

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

type ProcessQueryReply 

type ProcessQueryReply struct {
	ProcessList          []api.Process `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedProcessQueryReply 

func NewPopulatedProcessQueryReply(r randyControl, easy bool) *ProcessQueryReply

func (*ProcessQueryReply) Descriptor 

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

func (*ProcessQueryReply) Equal 

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

func (*ProcessQueryReply) GetProcessList 

func (m *ProcessQueryReply) GetProcessList() []api.Process

func (*ProcessQueryReply) GoString 

func (this *ProcessQueryReply) GoString() string

func (*ProcessQueryReply) Marshal 

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

func (*ProcessQueryReply) MarshalTo 

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

func (*ProcessQueryReply) MarshalToSizedBuffer 

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

func (*ProcessQueryReply) ProtoMessage 

func (*ProcessQueryReply) ProtoMessage()

func (*ProcessQueryReply) Reset 

func (m *ProcessQueryReply) Reset()

func (*ProcessQueryReply) Size 

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

func (*ProcessQueryReply) String 

func (this *ProcessQueryReply) String() string

func (*ProcessQueryReply) Unmarshal 

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

func (*ProcessQueryReply) VerboseEqual 

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

func (*ProcessQueryReply) XXX_DiscardUnknown 

func (m *ProcessQueryReply) XXX_DiscardUnknown()

func (*ProcessQueryReply) XXX_Marshal 

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

func (*ProcessQueryReply) XXX_Merge 

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

func (*ProcessQueryReply) XXX_Size 

func (m *ProcessQueryReply) XXX_Size() int

func (*ProcessQueryReply) XXX_Unmarshal 

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

type ProcessQueryRequest 

type ProcessQueryRequest struct {
	Filter               api.ProcessFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedProcessQueryRequest 

func NewPopulatedProcessQueryRequest(r randyControl, easy bool) *ProcessQueryRequest

func (*ProcessQueryRequest) Descriptor 

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

func (*ProcessQueryRequest) Equal 

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

func (*ProcessQueryRequest) GetFilter 

func (m *ProcessQueryRequest) GetFilter() api.ProcessFilter

func (*ProcessQueryRequest) GoString 

func (this *ProcessQueryRequest) GoString() string

func (*ProcessQueryRequest) Marshal 

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

func (*ProcessQueryRequest) MarshalTo 

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

func (*ProcessQueryRequest) MarshalToSizedBuffer 

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

func (*ProcessQueryRequest) ProtoMessage 

func (*ProcessQueryRequest) ProtoMessage()

func (*ProcessQueryRequest) Reset 

func (m *ProcessQueryRequest) Reset()

func (*ProcessQueryRequest) Size 

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

func (*ProcessQueryRequest) String 

func (this *ProcessQueryRequest) String() string

func (*ProcessQueryRequest) Unmarshal 

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

func (*ProcessQueryRequest) VerboseEqual 

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

func (*ProcessQueryRequest) XXX_DiscardUnknown 

func (m *ProcessQueryRequest) XXX_DiscardUnknown()

func (*ProcessQueryRequest) XXX_Marshal 

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

func (*ProcessQueryRequest) XXX_Merge 

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

func (*ProcessQueryRequest) XXX_Size 

func (m *ProcessQueryRequest) XXX_Size() int

func (*ProcessQueryRequest) XXX_Unmarshal 

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

type ProcessReplayRequest added in v3.2.0 

type ProcessReplayRequest struct {
	Process              api.Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process"`
	Match                bool        `protobuf:"varint,2,opt,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedProcessReplayRequest added in v3.2.0 

func NewPopulatedProcessReplayRequest(r randyControl, easy bool) *ProcessReplayRequest

func (*ProcessReplayRequest) Descriptor added in v3.2.0 

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

func (*ProcessReplayRequest) Equal added in v3.2.0 

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

func (*ProcessReplayRequest) GetMatch added in v3.2.0 

func (m *ProcessReplayRequest) GetMatch() bool

func (*ProcessReplayRequest) GetProcess added in v3.2.0 

func (m *ProcessReplayRequest) GetProcess() api.Process

func (*ProcessReplayRequest) GoString added in v3.2.0 

func (this *ProcessReplayRequest) GoString() string

func (*ProcessReplayRequest) Marshal added in v3.2.0 

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

func (*ProcessReplayRequest) MarshalTo added in v3.2.0 

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

func (*ProcessReplayRequest) MarshalToSizedBuffer added in v3.2.0 

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

func (*ProcessReplayRequest) ProtoMessage added in v3.2.0 

func (*ProcessReplayRequest) ProtoMessage()

func (*ProcessReplayRequest) Reset added in v3.2.0 

func (m *ProcessReplayRequest) Reset()

func (*ProcessReplayRequest) Size added in v3.2.0 

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

func (*ProcessReplayRequest) String added in v3.2.0 

func (this *ProcessReplayRequest) String() string

func (*ProcessReplayRequest) Unmarshal added in v3.2.0 

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

func (*ProcessReplayRequest) VerboseEqual added in v3.2.0 

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

func (*ProcessReplayRequest) XXX_DiscardUnknown added in v3.2.0 

func (m *ProcessReplayRequest) XXX_DiscardUnknown()

func (*ProcessReplayRequest) XXX_Marshal added in v3.2.0 

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

func (*ProcessReplayRequest) XXX_Merge added in v3.2.0 

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

func (*ProcessReplayRequest) XXX_Size added in v3.2.0 

func (m *ProcessReplayRequest) XXX_Size() int

func (*ProcessReplayRequest) XXX_Unmarshal added in v3.2.0 

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

type ProcessServer 

type ProcessServer interface {
	Query(ctx context.Context, req ProcessQueryRequest, pushRep func(ProcessQueryReply)) (err error)
	QuerySummary(ctx context.Context, req ProcessQueryRequest, pushRep func(ProcessSummary)) (err error)
	Control(ctx context.Context, req ProcessControlRequest) (err error)
	Export(ctx context.Context, req ProcessExportRequest) (resp ProcessExportReply, err error)
	ExportStream(ctx context.Context, req ProcessExportRequest, pushRep func(OctetStreamList)) (err error)
	Purge(ctx context.Context, req ProcessPurgeRequest, pushRep func(TaskProgress)) (err error)
	Replay(ctx context.Context, req ProcessReplayRequest) (resp xbus_io_go_xbus_v3_api.Process, err error)
}

ProcessServer is the interface that providers of the service Process should implement.

type ProcessSummary added in v3.2.0 

type ProcessSummary struct {
	Entries              []*ProcessSummary_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func NewPopulatedProcessSummary added in v3.2.0 

func NewPopulatedProcessSummary(r randyControl, easy bool) *ProcessSummary

func (*ProcessSummary) Descriptor added in v3.2.0 

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

func (*ProcessSummary) Equal added in v3.2.0 

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

func (*ProcessSummary) GetEntries added in v3.2.0 

func (m *ProcessSummary) GetEntries() []*ProcessSummary_Entry

func (*ProcessSummary) GoString added in v3.2.0 

func (this *ProcessSummary) GoString() string

func (*ProcessSummary) Marshal added in v3.2.0 

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

func (*ProcessSummary) MarshalTo added in v3.2.0 

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

func (*ProcessSummary) MarshalToSizedBuffer added in v3.2.0 

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

func (*ProcessSummary) ProtoMessage added in v3.2.0 

func (*ProcessSummary) ProtoMessage()

func (*ProcessSummary) Reset added in v3.2.0 

func (m *ProcessSummary) Reset()

func (*ProcessSummary) Size added in v3.2.0 

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

func (*ProcessSummary) String added in v3.2.0 

func (this *ProcessSummary) String() string

func (*ProcessSummary) Unmarshal added in v3.2.0 

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

func (*ProcessSummary) VerboseEqual added in v3.2.0 

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

func (*ProcessSummary) XXX_DiscardUnknown added in v3.2.0 

func (m *ProcessSummary) XXX_DiscardUnknown()

func (*ProcessSummary) XXX_Marshal added in v3.2.0 

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

func (*ProcessSummary) XXX_Merge added in v3.2.0 

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

func (*ProcessSummary) XXX_Size added in v3.2.0 

func (m *ProcessSummary) XXX_Size() int

func (*ProcessSummary) XXX_Unmarshal added in v3.2.0 

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

type ProcessSummary_Entry added in v3.2.0 

type ProcessSummary_Entry struct {
	PipelineID           xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,1,opt,name=pipelineID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"pipelineID"`
	EmitterID            xbus_io_go_xbus_v3_api.UUID `protobuf:"bytes,2,opt,name=emitterID,proto3,customtype=xbus.io/go-xbus/v3/api.UUID" json:"emitterID"`
	Status               api.Process_Status          `protobuf:"varint,3,opt,name=status,proto3,enum=xbus.Process_Status" json:"status,omitempty"`
	ResultAcked          bool                        `protobuf:"varint,4,opt,name=resultAcked,proto3" json:"resultAcked,omitempty"`
	Count                uint64                      `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedProcessSummary_Entry added in v3.2.0 

func NewPopulatedProcessSummary_Entry(r randyControl, easy bool) *ProcessSummary_Entry

func (*ProcessSummary_Entry) Descriptor added in v3.2.0 

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

func (*ProcessSummary_Entry) Equal added in v3.2.0 

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

func (*ProcessSummary_Entry) GetCount added in v3.2.0 

func (m *ProcessSummary_Entry) GetCount() uint64

func (*ProcessSummary_Entry) GetResultAcked added in v3.2.0 

func (m *ProcessSummary_Entry) GetResultAcked() bool

func (*ProcessSummary_Entry) GetStatus added in v3.2.0 

func (m *ProcessSummary_Entry) GetStatus() api.Process_Status

func (*ProcessSummary_Entry) GoString added in v3.2.0 

func (this *ProcessSummary_Entry) GoString() string

func (*ProcessSummary_Entry) Marshal added in v3.2.0 

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

func (*ProcessSummary_Entry) MarshalTo added in v3.2.0 

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

func (*ProcessSummary_Entry) MarshalToSizedBuffer added in v3.2.0 

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

func (*ProcessSummary_Entry) ProtoMessage added in v3.2.0 

func (*ProcessSummary_Entry) ProtoMessage()

func (*ProcessSummary_Entry) Reset added in v3.2.0 

func (m *ProcessSummary_Entry) Reset()

func (*ProcessSummary_Entry) Size added in v3.2.0 

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

func (*ProcessSummary_Entry) String added in v3.2.0 

func (this *ProcessSummary_Entry) String() string

func (*ProcessSummary_Entry) Unmarshal added in v3.2.0 

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

func (*ProcessSummary_Entry) VerboseEqual added in v3.2.0 

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

func (*ProcessSummary_Entry) XXX_DiscardUnknown added in v3.2.0 

func (m *ProcessSummary_Entry) XXX_DiscardUnknown()

func (*ProcessSummary_Entry) XXX_Marshal added in v3.2.0 

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

func (*ProcessSummary_Entry) XXX_Merge added in v3.2.0 

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

func (*ProcessSummary_Entry) XXX_Size added in v3.2.0 

func (m *ProcessSummary_Entry) XXX_Size() int

func (*ProcessSummary_Entry) XXX_Unmarshal added in v3.2.0 

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

type StorageStat added in v3.2.0 

type StorageStat struct {
	Entries              []StorageStat_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func NewPopulatedStorageStat added in v3.2.0 

func NewPopulatedStorageStat(r randyControl, easy bool) *StorageStat

func (*StorageStat) Descriptor added in v3.2.0 

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

func (*StorageStat) Equal added in v3.2.0 

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

func (*StorageStat) GetEntries added in v3.2.0 

func (m *StorageStat) GetEntries() []StorageStat_Entry

func (*StorageStat) GoString added in v3.2.0 

func (this *StorageStat) GoString() string

func (*StorageStat) Marshal added in v3.2.0 

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

func (*StorageStat) MarshalTo added in v3.2.0 

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

func (*StorageStat) MarshalToSizedBuffer added in v3.2.0 

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

func (*StorageStat) ProtoMessage added in v3.2.0 

func (*StorageStat) ProtoMessage()

func (*StorageStat) Reset added in v3.2.0 

func (m *StorageStat) Reset()

func (*StorageStat) Size added in v3.2.0 

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

func (*StorageStat) String added in v3.2.0 

func (this *StorageStat) String() string

func (*StorageStat) Unmarshal added in v3.2.0 

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

func (*StorageStat) VerboseEqual added in v3.2.0 

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

func (*StorageStat) XXX_DiscardUnknown added in v3.2.0 

func (m *StorageStat) XXX_DiscardUnknown()

func (*StorageStat) XXX_Marshal added in v3.2.0 

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

func (*StorageStat) XXX_Merge added in v3.2.0 

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

func (*StorageStat) XXX_Size added in v3.2.0 

func (m *StorageStat) XXX_Size() int

func (*StorageStat) XXX_Unmarshal added in v3.2.0 

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

type StorageStat_Entry added in v3.2.0 

type StorageStat_Entry struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 StorageType `protobuf:"varint,2,opt,name=type,proto3,enum=xbus.control.StorageType" json:"type,omitempty"`
	Implementation       string      `protobuf:"bytes,3,opt,name=implementation,proto3" json:"implementation,omitempty"`
	Count                uint64      `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	EstimatedSize        uint64      `protobuf:"varint,5,opt,name=estimatedSize,proto3" json:"estimatedSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedStorageStat_Entry added in v3.2.0 

func NewPopulatedStorageStat_Entry(r randyControl, easy bool) *StorageStat_Entry

func (*StorageStat_Entry) Descriptor added in v3.2.0 

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

func (*StorageStat_Entry) Equal added in v3.2.0 

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

func (*StorageStat_Entry) GetCount added in v3.2.0 

func (m *StorageStat_Entry) GetCount() uint64

func (*StorageStat_Entry) GetEstimatedSize added in v3.2.0 

func (m *StorageStat_Entry) GetEstimatedSize() uint64

func (*StorageStat_Entry) GetImplementation added in v3.2.0 

func (m *StorageStat_Entry) GetImplementation() string

func (*StorageStat_Entry) GetName added in v3.2.0 

func (m *StorageStat_Entry) GetName() string

func (*StorageStat_Entry) GetType added in v3.2.0 

func (m *StorageStat_Entry) GetType() StorageType

func (*StorageStat_Entry) GoString added in v3.2.0 

func (this *StorageStat_Entry) GoString() string

func (*StorageStat_Entry) Marshal added in v3.2.0 

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

func (*StorageStat_Entry) MarshalTo added in v3.2.0 

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

func (*StorageStat_Entry) MarshalToSizedBuffer added in v3.2.0 

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

func (*StorageStat_Entry) ProtoMessage added in v3.2.0 

func (*StorageStat_Entry) ProtoMessage()

func (*StorageStat_Entry) Reset added in v3.2.0 

func (m *StorageStat_Entry) Reset()

func (*StorageStat_Entry) Size added in v3.2.0 

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

func (*StorageStat_Entry) String added in v3.2.0 

func (this *StorageStat_Entry) String() string

func (*StorageStat_Entry) Unmarshal added in v3.2.0 

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

func (*StorageStat_Entry) VerboseEqual added in v3.2.0 

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

func (*StorageStat_Entry) XXX_DiscardUnknown added in v3.2.0 

func (m *StorageStat_Entry) XXX_DiscardUnknown()

func (*StorageStat_Entry) XXX_Marshal added in v3.2.0 

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

func (*StorageStat_Entry) XXX_Merge added in v3.2.0 

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

func (*StorageStat_Entry) XXX_Size added in v3.2.0 

func (m *StorageStat_Entry) XXX_Size() int

func (*StorageStat_Entry) XXX_Unmarshal added in v3.2.0 

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

type StorageType added in v3.2.0 

type StorageType int32
const (
	StorageType_UNDEFINED StorageType = 0
	StorageType_ACCOUNT   StorageType = 1
	StorageType_ACTOR     StorageType = 2
	StorageType_ENVELOPE  StorageType = 3
	StorageType_JOB       StorageType = 4
	StorageType_LOG       StorageType = 5
	StorageType_PASSWORD  StorageType = 6
	StorageType_PIPELINE  StorageType = 7
	StorageType_PROCESS   StorageType = 8
	StorageType_SESSION   StorageType = 9
)

func (StorageType) EnumDescriptor added in v3.2.0 

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

func (StorageType) String added in v3.2.0 

func (x StorageType) String() string

type TaskProgress 

type TaskProgress struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Progression          uint32   `protobuf:"varint,2,opt,name=progression,proto3" json:"progression,omitempty"`
	MaxProgression       uint32   `protobuf:"varint,3,opt,name=maxProgression,proto3" json:"maxProgression,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTaskProgress 

func NewPopulatedTaskProgress(r randyControl, easy bool) *TaskProgress

func (*TaskProgress) Descriptor 

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

func (*TaskProgress) Equal 

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

func (*TaskProgress) GetMaxProgression 

func (m *TaskProgress) GetMaxProgression() uint32

func (*TaskProgress) GetMessage 

func (m *TaskProgress) GetMessage() string

func (*TaskProgress) GetProgression 

func (m *TaskProgress) GetProgression() uint32

func (*TaskProgress) GoString 

func (this *TaskProgress) GoString() string

func (*TaskProgress) Marshal 

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

func (*TaskProgress) MarshalTo 

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

func (*TaskProgress) MarshalToSizedBuffer 

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

func (*TaskProgress) ProtoMessage 

func (*TaskProgress) ProtoMessage()

func (*TaskProgress) Reset 

func (m *TaskProgress) Reset()

func (*TaskProgress) Size 

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

func (*TaskProgress) String 

func (this *TaskProgress) String() string

func (*TaskProgress) Unmarshal 

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

func (*TaskProgress) VerboseEqual 

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

func (*TaskProgress) XXX_DiscardUnknown 

func (m *TaskProgress) XXX_DiscardUnknown()

func (*TaskProgress) XXX_Marshal 

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

func (*TaskProgress) XXX_Merge 

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

func (*TaskProgress) XXX_Size 

func (m *TaskProgress) XXX_Size() int

func (*TaskProgress) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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