control

package
Version: 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

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 (*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 (*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 (*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

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 (*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 (*ProcessClient) Query

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 (*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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL