control

package
v0.0.0-...-05a97e5 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2020 License: MIT Imports: 19 Imported by: 0

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",
}
View Source 
var ProcessControlRequest_Command_value = map[string]int32{
	"NONE":   0,
	"PAUSE":  1,
	"RESUME": 2,
	"CANCEL": 3,
}

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_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_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_api.Account, err error)

func (*AccountClient) Update 

func (c *AccountClient) Update(req AccountUpdateRequest) (resp xbus_io_go_xbus_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_api.UUID `protobuf:"bytes,1,opt,name=accountID,proto3,customtype=xbus.io/go-xbus/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_api.UUID `protobuf:"bytes,1,opt,name=accountID,proto3,customtype=xbus.io/go-xbus/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_api.Account, err error)
	Delete(ctx context.Context, req AccountIDRequest) (err error)
	RenewAPIKey(ctx context.Context, req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
	GetAPIKey(ctx context.Context, req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
	SetAPIKey(ctx context.Context, req AccountUpdateRequest) (resp xbus_io_go_xbus_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
	// 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 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) 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)
}

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

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_api.UUID `protobuf:"bytes,3,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/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_api.UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/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_api.PipelineInfo) (resp xbus_io_go_xbus_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_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_api.PipelineInfo) (resp PipelineSetStatusReply, err error)
	GetGraph(ctx context.Context, req xbus_io_go_xbus_api.PipelineInfo) (resp xbus_io_go_xbus_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

type ProcessControlRequest 

type ProcessControlRequest struct {
	ProcessID            xbus_io_go_xbus_api.UUID      `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/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
)

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_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/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_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/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 ProcessServer 

type ProcessServer interface {
	Query(ctx context.Context, req ProcessQueryRequest, pushRep func(ProcessQueryReply)) (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)
}

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

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.