control

package
v4.0.0-...-7e265f1 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: MIT Imports: 13 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 (
	StorageType_name = map[int32]string{
		0: "UNDEFINED",
		1: "ACCOUNT",
		2: "ACTOR",
		3: "ENVELOPE",
		4: "JOB",
		5: "LOG",
		6: "PASSWORD",
		7: "PIPELINE",
		8: "PROCESS",
		9: "SESSION",
	}
	StorageType_value = map[string]int32{
		"UNDEFINED": 0,
		"ACCOUNT":   1,
		"ACTOR":     2,
		"ENVELOPE":  3,
		"JOB":       4,
		"LOG":       5,
		"PASSWORD":  6,
		"PIPELINE":  7,
		"PROCESS":   8,
		"SESSION":   9,
	}
)

Enum value maps for StorageType.

View Source 
var (
	ProcessControlRequest_Command_name = map[int32]string{
		0: "NONE",
		1: "PAUSE",
		2: "RESUME",
		3: "CANCEL",
		4: "REPLAY",
	}
	ProcessControlRequest_Command_value = map[string]int32{
		"NONE":   0,
		"PAUSE":  1,
		"RESUME": 2,
		"CANCEL": 3,
		"REPLAY": 4,
	}
)

Enum value maps for ProcessControlRequest_Command.

View Source 
var File_xbus_control_proto protoreflect.FileDescriptor

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

func (*AccountClient) GetAPIKey 

func (c *AccountClient) GetAPIKey(req *AccountIDRequest) (*xbus_io_go_xbus_v4_api.Account, error)

func (*AccountClient) List 

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

func (*AccountClient) PasswordSet 

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

func (*AccountClient) RenewAPIKey 

func (c *AccountClient) RenewAPIKey(req *AccountIDRequest) (*xbus_io_go_xbus_v4_api.Account, error)

func (*AccountClient) ResetCert 

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

func (*AccountClient) SetAPIKey 

func (c *AccountClient) SetAPIKey(req *AccountUpdateRequest) (*xbus_io_go_xbus_v4_api.Account, error)

func (*AccountClient) Update 

func (c *AccountClient) Update(req *AccountUpdateRequest) (*xbus_io_go_xbus_v4_api.Account, 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 []byte `protobuf:"bytes,1,opt,name=accountID,proto3" json:"accountID,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountIDRequest) Descriptor deprecated 

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

Deprecated: Use AccountIDRequest.ProtoReflect.Descriptor instead.

func (*AccountIDRequest) GetAccountID 

func (x *AccountIDRequest) GetAccountID() []byte

func (*AccountIDRequest) GetAccountIDAsUUID 

func (x *AccountIDRequest) GetAccountIDAsUUID() api.UUID

func (*AccountIDRequest) ProtoMessage 

func (*AccountIDRequest) ProtoMessage()

func (*AccountIDRequest) ProtoReflect 

func (x *AccountIDRequest) ProtoReflect() protoreflect.Message

func (*AccountIDRequest) Reset 

func (x *AccountIDRequest) Reset()

func (*AccountIDRequest) String 

func (x *AccountIDRequest) String() string

type AccountListReply 

type AccountListReply struct {
	AccountList []*api.Account `protobuf:"bytes,1,rep,name=accountList,proto3" json:"accountList,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountListReply) Descriptor deprecated 

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

Deprecated: Use AccountListReply.ProtoReflect.Descriptor instead.

func (*AccountListReply) GetAccountList 

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

func (*AccountListReply) ProtoMessage 

func (*AccountListReply) ProtoMessage()

func (*AccountListReply) ProtoReflect 

func (x *AccountListReply) ProtoReflect() protoreflect.Message

func (*AccountListReply) Reset 

func (x *AccountListReply) Reset()

func (*AccountListReply) String 

func (x *AccountListReply) String() string

type AccountListRequest 

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

func (*AccountListRequest) Descriptor deprecated 

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

Deprecated: Use AccountListRequest.ProtoReflect.Descriptor instead.

func (*AccountListRequest) ProtoMessage 

func (*AccountListRequest) ProtoMessage()

func (*AccountListRequest) ProtoReflect 

func (x *AccountListRequest) ProtoReflect() protoreflect.Message

func (*AccountListRequest) Reset 

func (x *AccountListRequest) Reset()

func (*AccountListRequest) String 

func (x *AccountListRequest) String() string

type AccountPasswordSetRequest 

type AccountPasswordSetRequest struct {
	AccountID []byte `protobuf:"bytes,1,opt,name=accountID,proto3" json:"accountID,omitempty"`
	Password  string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountPasswordSetRequest) Descriptor deprecated 

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

Deprecated: Use AccountPasswordSetRequest.ProtoReflect.Descriptor instead.

func (*AccountPasswordSetRequest) GetAccountID 

func (x *AccountPasswordSetRequest) GetAccountID() []byte

func (*AccountPasswordSetRequest) GetAccountIDAsUUID 

func (x *AccountPasswordSetRequest) GetAccountIDAsUUID() api.UUID

func (*AccountPasswordSetRequest) GetPassword 

func (x *AccountPasswordSetRequest) GetPassword() string

func (*AccountPasswordSetRequest) ProtoMessage 

func (*AccountPasswordSetRequest) ProtoMessage()

func (*AccountPasswordSetRequest) ProtoReflect 

func (x *AccountPasswordSetRequest) ProtoReflect() protoreflect.Message

func (*AccountPasswordSetRequest) Reset 

func (x *AccountPasswordSetRequest) Reset()

func (*AccountPasswordSetRequest) String 

func (x *AccountPasswordSetRequest) String() string

type AccountServer 

type AccountServer interface {
	List(ctx context.Context, req *AccountListRequest) (*AccountListReply, error)
	Update(ctx context.Context, req *AccountUpdateRequest) (*xbus_io_go_xbus_v4_api.Account, error)
	Delete(ctx context.Context, req *AccountIDRequest) error
	RenewAPIKey(ctx context.Context, req *AccountIDRequest) (*xbus_io_go_xbus_v4_api.Account, error)
	GetAPIKey(ctx context.Context, req *AccountIDRequest) (*xbus_io_go_xbus_v4_api.Account, error)
	SetAPIKey(ctx context.Context, req *AccountUpdateRequest) (*xbus_io_go_xbus_v4_api.Account, error)
	ResetCert(ctx context.Context, req *AccountIDRequest) error
	PasswordSet(ctx context.Context, req *AccountPasswordSetRequest) 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,omitempty"`
	Expire  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire,proto3" json:"expire,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountUpdateRequest) Descriptor deprecated 

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

Deprecated: Use AccountUpdateRequest.ProtoReflect.Descriptor instead.

func (*AccountUpdateRequest) GetAccount 

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

func (*AccountUpdateRequest) GetExpire 

func (x *AccountUpdateRequest) GetExpire() *timestamppb.Timestamp

func (*AccountUpdateRequest) ProtoMessage 

func (*AccountUpdateRequest) ProtoMessage()

func (*AccountUpdateRequest) ProtoReflect 

func (x *AccountUpdateRequest) ProtoReflect() protoreflect.Message

func (*AccountUpdateRequest) Reset 

func (x *AccountUpdateRequest) Reset()

func (*AccountUpdateRequest) String 

func (x *AccountUpdateRequest) String() string

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) (*ActorReply, error)

func (*ActorClient) Delete 

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

func (*ActorClient) Query 

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

func (*ActorClient) Update 

func (c *ActorClient) Update(req *ActorRequest) (*ActorReply, 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,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorReply) Descriptor deprecated 

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

Deprecated: Use ActorReply.ProtoReflect.Descriptor instead.

func (*ActorReply) GetActorList 

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

func (*ActorReply) ProtoMessage 

func (*ActorReply) ProtoMessage()

func (*ActorReply) ProtoReflect 

func (x *ActorReply) ProtoReflect() protoreflect.Message

func (*ActorReply) Reset 

func (x *ActorReply) Reset()

func (*ActorReply) String 

func (x *ActorReply) String() string

type ActorRequest 

type ActorRequest struct {
	ActorList []*api.Actor `protobuf:"bytes,1,rep,name=actorList,proto3" json:"actorList,omitempty"`
	// contains filtered or unexported fields
}

func (*ActorRequest) Descriptor deprecated 

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

Deprecated: Use ActorRequest.ProtoReflect.Descriptor instead.

func (*ActorRequest) GetActorList 

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

func (*ActorRequest) ProtoMessage 

func (*ActorRequest) ProtoMessage()

func (*ActorRequest) ProtoReflect 

func (x *ActorRequest) ProtoReflect() protoreflect.Message

func (*ActorRequest) Reset 

func (x *ActorRequest) Reset()

func (*ActorRequest) String 

func (x *ActorRequest) String() string

type ActorServer 

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

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

type Client 

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

func NewClient 

func NewClient(nc nrpc.NatsConn) *Client

func (*Client) SetEncoding 

func (c *Client) SetEncoding(encoding string)

func (*Client) SetTimeout 

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

type DebugClient 

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

func NewDebugClient 

func NewDebugClient(nc nrpc.NatsConn) *DebugClient

func (*DebugClient) Info 

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

type DebugHandler 

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

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

func NewDebugConcurrentHandler 

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

func NewDebugHandler 

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

func (*DebugHandler) Handler 

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

func (*DebugHandler) SetEncodings 

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

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

func (*DebugHandler) Subject 

func (h *DebugHandler) Subject() string

type DebugInfoRequest 

type DebugInfoRequest struct {

	// / The debug information entry to return
	Entry string `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// / Arguments to the info command
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// / The output format. May not apply to all the possible entries
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugInfoRequest) Descriptor deprecated 

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

Deprecated: Use DebugInfoRequest.ProtoReflect.Descriptor instead.

func (*DebugInfoRequest) GetArgs 

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

func (*DebugInfoRequest) GetEntry 

func (x *DebugInfoRequest) GetEntry() string

func (*DebugInfoRequest) GetFormat 

func (x *DebugInfoRequest) GetFormat() string

func (*DebugInfoRequest) ProtoMessage 

func (*DebugInfoRequest) ProtoMessage()

func (*DebugInfoRequest) ProtoReflect 

func (x *DebugInfoRequest) ProtoReflect() protoreflect.Message

func (*DebugInfoRequest) Reset 

func (x *DebugInfoRequest) Reset()

func (*DebugInfoRequest) String 

func (x *DebugInfoRequest) String() string

type DebugServer 

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

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

type EnvelopeClient 

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

func NewEnvelopeClient 

func NewEnvelopeClient(nc nrpc.NatsConn) *EnvelopeClient

func (*EnvelopeClient) GetStorageStat 

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

func (*EnvelopeClient) Purge 

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

type EnvelopeHandler 

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

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

func NewEnvelopeConcurrentHandler 

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

func NewEnvelopeHandler 

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

func (*EnvelopeHandler) Handler 

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

func (*EnvelopeHandler) SetEncodings 

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

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

func (*EnvelopeHandler) Subject 

func (h *EnvelopeHandler) Subject() string

type EnvelopeServer 

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

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

type LogsClient 

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

func NewLogsClient 

func NewLogsClient(nc nrpc.NatsConn) *LogsClient

func (*LogsClient) GetStorageStat 

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

func (*LogsClient) Purge 

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

type LogsHandler 

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

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

func NewLogsConcurrentHandler 

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

func NewLogsHandler 

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

func (*LogsHandler) Handler 

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

func (*LogsHandler) SetEncodings 

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

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

func (*LogsHandler) Subject 

func (h *LogsHandler) Subject() string

type LogsPurgeReply 

type LogsPurgeReply struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsPurgeReply) Descriptor deprecated 

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

Deprecated: Use LogsPurgeReply.ProtoReflect.Descriptor instead.

func (*LogsPurgeReply) GetCount 

func (x *LogsPurgeReply) GetCount() int64

func (*LogsPurgeReply) ProtoMessage 

func (*LogsPurgeReply) ProtoMessage()

func (*LogsPurgeReply) ProtoReflect 

func (x *LogsPurgeReply) ProtoReflect() protoreflect.Message

func (*LogsPurgeReply) Reset 

func (x *LogsPurgeReply) Reset()

func (*LogsPurgeReply) String 

func (x *LogsPurgeReply) String() string

type LogsPurgeRequest 

type LogsPurgeRequest struct {
	Before *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsPurgeRequest) Descriptor deprecated 

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

Deprecated: Use LogsPurgeRequest.ProtoReflect.Descriptor instead.

func (*LogsPurgeRequest) GetBefore 

func (x *LogsPurgeRequest) GetBefore() *timestamppb.Timestamp

func (*LogsPurgeRequest) ProtoMessage 

func (*LogsPurgeRequest) ProtoMessage()

func (*LogsPurgeRequest) ProtoReflect 

func (x *LogsPurgeRequest) ProtoReflect() protoreflect.Message

func (*LogsPurgeRequest) Reset 

func (x *LogsPurgeRequest) Reset()

func (*LogsPurgeRequest) String 

func (x *LogsPurgeRequest) String() string

type LogsServer 

type LogsServer interface {
	Purge(ctx context.Context, req *LogsPurgeRequest, pushRep func(*LogsPurgeReply)) error
	GetStorageStat(ctx context.Context) (*StorageStat, 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,omitempty"`
	Progression    int64                    `protobuf:"varint,2,opt,name=progression,proto3" json:"progression,omitempty"`
	MaxProgression int64                    `protobuf:"varint,3,opt,name=maxProgression,proto3" json:"maxProgression,omitempty"`
	// contains filtered or unexported fields
}

func (*OctetStreamList) Descriptor deprecated 

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

Deprecated: Use OctetStreamList.ProtoReflect.Descriptor instead.

func (*OctetStreamList) GetChunks 

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

func (*OctetStreamList) GetMaxProgression 

func (x *OctetStreamList) GetMaxProgression() int64

func (*OctetStreamList) GetProgression 

func (x *OctetStreamList) GetProgression() int64

func (*OctetStreamList) ProtoMessage 

func (*OctetStreamList) ProtoMessage()

func (*OctetStreamList) ProtoReflect 

func (x *OctetStreamList) ProtoReflect() protoreflect.Message

func (*OctetStreamList) Reset 

func (x *OctetStreamList) Reset()

func (*OctetStreamList) String 

func (x *OctetStreamList) String() string

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"`
	// contains filtered or unexported fields
}

func (*OctetStreamList_Chunk) Descriptor deprecated 

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

Deprecated: Use OctetStreamList_Chunk.ProtoReflect.Descriptor instead.

func (*OctetStreamList_Chunk) GetData 

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

func (*OctetStreamList_Chunk) GetIndex 

func (x *OctetStreamList_Chunk) GetIndex() int64

func (*OctetStreamList_Chunk) ProtoMessage 

func (*OctetStreamList_Chunk) ProtoMessage()

func (*OctetStreamList_Chunk) ProtoReflect 

func (x *OctetStreamList_Chunk) ProtoReflect() protoreflect.Message

func (*OctetStreamList_Chunk) Reset 

func (x *OctetStreamList_Chunk) Reset()

func (*OctetStreamList_Chunk) String 

func (x *OctetStreamList_Chunk) String() string

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) 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,omitempty"`
	// contains filtered or unexported fields
}

func (*PMProcessQueryReply) Descriptor deprecated 

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

Deprecated: Use PMProcessQueryReply.ProtoReflect.Descriptor instead.

func (*PMProcessQueryReply) GetPMProcessList 

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

func (*PMProcessQueryReply) ProtoMessage 

func (*PMProcessQueryReply) ProtoMessage()

func (*PMProcessQueryReply) ProtoReflect 

func (x *PMProcessQueryReply) ProtoReflect() protoreflect.Message

func (*PMProcessQueryReply) Reset 

func (x *PMProcessQueryReply) Reset()

func (*PMProcessQueryReply) String 

func (x *PMProcessQueryReply) String() string

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    [][]byte     `protobuf:"bytes,3,rep,name=processIDs,proto3" json:"processIDs,omitempty"`
	ReturnLogs    bool         `protobuf:"varint,4,opt,name=returnLogs,proto3" json:"returnLogs,omitempty"`
	// contains filtered or unexported fields
}

func (*PMProcessQueryRequest) Descriptor deprecated 

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

Deprecated: Use PMProcessQueryRequest.ProtoReflect.Descriptor instead.

func (*PMProcessQueryRequest) GetIncludeClosed 

func (x *PMProcessQueryRequest) GetIncludeClosed() bool

func (*PMProcessQueryRequest) GetLevel 

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

func (*PMProcessQueryRequest) GetProcessIDs 

func (x *PMProcessQueryRequest) GetProcessIDs() [][]byte

func (*PMProcessQueryRequest) GetProcessIDsAsUUIDSlice 

func (x *PMProcessQueryRequest) GetProcessIDsAsUUIDSlice() api.UUIDSlice

func (*PMProcessQueryRequest) GetReturnLogs 

func (x *PMProcessQueryRequest) GetReturnLogs() bool

func (*PMProcessQueryRequest) ProtoMessage 

func (*PMProcessQueryRequest) ProtoMessage()

func (*PMProcessQueryRequest) ProtoReflect 

func (x *PMProcessQueryRequest) ProtoReflect() protoreflect.Message

func (*PMProcessQueryRequest) Reset 

func (x *PMProcessQueryRequest) Reset()

func (*PMProcessQueryRequest) String 

func (x *PMProcessQueryRequest) String() string

type PMProcessServer 

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

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

type PMProcessSetStatusRequest 

type PMProcessSetStatusRequest struct {
	ProcessID []byte               `protobuf:"bytes,1,opt,name=processID,proto3" json:"processID,omitempty"`
	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"`
	// contains filtered or unexported fields
}

func (*PMProcessSetStatusRequest) Descriptor deprecated 

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

Deprecated: Use PMProcessSetStatusRequest.ProtoReflect.Descriptor instead.

func (*PMProcessSetStatusRequest) GetComment 

func (x *PMProcessSetStatusRequest) GetComment() string

func (*PMProcessSetStatusRequest) GetProcessID 

func (x *PMProcessSetStatusRequest) GetProcessID() []byte

func (*PMProcessSetStatusRequest) GetProcessIDAsUUID 

func (x *PMProcessSetStatusRequest) GetProcessIDAsUUID() api.UUID

func (*PMProcessSetStatusRequest) GetStatus 

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

func (*PMProcessSetStatusRequest) ProtoMessage 

func (*PMProcessSetStatusRequest) ProtoMessage()

func (*PMProcessSetStatusRequest) ProtoReflect 

func (x *PMProcessSetStatusRequest) ProtoReflect() protoreflect.Message

func (*PMProcessSetStatusRequest) Reset 

func (x *PMProcessSetStatusRequest) Reset()

func (*PMProcessSetStatusRequest) String 

func (x *PMProcessSetStatusRequest) String() string

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_v4_api.PipelineInfo) (*xbus_io_go_xbus_v4_api.StringReply, error)

func (*PipelineClient) Query 

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

func (*PipelineClient) Save 

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

func (*PipelineClient) SetStatus 

func (c *PipelineClient) SetStatus(req *xbus_io_go_xbus_v4_api.PipelineInfo) (*PipelineSetStatusReply, 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,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineQueryReply) Descriptor deprecated 

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

Deprecated: Use PipelineQueryReply.ProtoReflect.Descriptor instead.

func (*PipelineQueryReply) GetPipelineList 

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

func (*PipelineQueryReply) ProtoMessage 

func (*PipelineQueryReply) ProtoMessage()

func (*PipelineQueryReply) ProtoReflect 

func (x *PipelineQueryReply) ProtoReflect() protoreflect.Message

func (*PipelineQueryReply) Reset 

func (x *PipelineQueryReply) Reset()

func (*PipelineQueryReply) String 

func (x *PipelineQueryReply) String() string

type PipelineQueryRequest 

type PipelineQueryRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineQueryRequest) Descriptor deprecated 

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

Deprecated: Use PipelineQueryRequest.ProtoReflect.Descriptor instead.

func (*PipelineQueryRequest) GetName 

func (x *PipelineQueryRequest) GetName() string

func (*PipelineQueryRequest) ProtoMessage 

func (*PipelineQueryRequest) ProtoMessage()

func (*PipelineQueryRequest) ProtoReflect 

func (x *PipelineQueryRequest) ProtoReflect() protoreflect.Message

func (*PipelineQueryRequest) Reset 

func (x *PipelineQueryRequest) Reset()

func (*PipelineQueryRequest) String 

func (x *PipelineQueryRequest) String() string

type PipelineSaveReply 

type PipelineSaveReply struct {
	Info               *api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	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"`
	// contains filtered or unexported fields
}

func (*PipelineSaveReply) Descriptor deprecated 

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

Deprecated: Use PipelineSaveReply.ProtoReflect.Descriptor instead.

func (*PipelineSaveReply) GetGraph 

func (x *PipelineSaveReply) GetGraph() string

func (*PipelineSaveReply) GetInfo 

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

func (*PipelineSaveReply) GetIsValid 

func (x *PipelineSaveReply) GetIsValid() bool

func (*PipelineSaveReply) GetValidationMessages 

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

func (*PipelineSaveReply) ProtoMessage 

func (*PipelineSaveReply) ProtoMessage()

func (*PipelineSaveReply) ProtoReflect 

func (x *PipelineSaveReply) ProtoReflect() protoreflect.Message

func (*PipelineSaveReply) Reset 

func (x *PipelineSaveReply) Reset()

func (*PipelineSaveReply) String 

func (x *PipelineSaveReply) String() string

type PipelineSaveRequest 

type PipelineSaveRequest struct {
	Info  *api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Graph string            `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineSaveRequest) Descriptor deprecated 

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

Deprecated: Use PipelineSaveRequest.ProtoReflect.Descriptor instead.

func (*PipelineSaveRequest) GetGraph 

func (x *PipelineSaveRequest) GetGraph() string

func (*PipelineSaveRequest) GetInfo 

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

func (*PipelineSaveRequest) ProtoMessage 

func (*PipelineSaveRequest) ProtoMessage()

func (*PipelineSaveRequest) ProtoReflect 

func (x *PipelineSaveRequest) ProtoReflect() protoreflect.Message

func (*PipelineSaveRequest) Reset 

func (x *PipelineSaveRequest) Reset()

func (*PipelineSaveRequest) String 

func (x *PipelineSaveRequest) String() string

type PipelineServer 

type PipelineServer interface {
	Query(ctx context.Context, req *PipelineQueryRequest) (*PipelineQueryReply, error)
	Save(ctx context.Context, req *PipelineSaveRequest) (*PipelineSaveReply, error)
	SetStatus(ctx context.Context, req *xbus_io_go_xbus_v4_api.PipelineInfo) (*PipelineSetStatusReply, error)
	GetGraph(ctx context.Context, req *xbus_io_go_xbus_v4_api.PipelineInfo) (*xbus_io_go_xbus_v4_api.StringReply, 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,omitempty"`
	IsValid            bool              `protobuf:"varint,2,opt,name=isValid,proto3" json:"isValid,omitempty"`
	ValidationMessages []string          `protobuf:"bytes,4,rep,name=validationMessages,proto3" json:"validationMessages,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineSetStatusReply) Descriptor deprecated 

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

Deprecated: Use PipelineSetStatusReply.ProtoReflect.Descriptor instead.

func (*PipelineSetStatusReply) GetInfo 

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

func (*PipelineSetStatusReply) GetIsValid 

func (x *PipelineSetStatusReply) GetIsValid() bool

func (*PipelineSetStatusReply) GetValidationMessages 

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

func (*PipelineSetStatusReply) ProtoMessage 

func (*PipelineSetStatusReply) ProtoMessage()

func (*PipelineSetStatusReply) ProtoReflect 

func (x *PipelineSetStatusReply) ProtoReflect() protoreflect.Message

func (*PipelineSetStatusReply) Reset 

func (x *PipelineSetStatusReply) Reset()

func (*PipelineSetStatusReply) String 

func (x *PipelineSetStatusReply) String() string

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

func (*ProcessClient) Export 

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

func (*ProcessClient) ExportStream 

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

func (*ProcessClient) Purge 

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

func (*ProcessClient) Query 

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

func (*ProcessClient) QuerySummary 

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

func (*ProcessClient) Replay 

func (c *ProcessClient) Replay(req *ProcessReplayRequest) (*xbus_io_go_xbus_v4_api.Process, error)

type ProcessControlRequest 

type ProcessControlRequest struct {
	ProcessID []byte                        `protobuf:"bytes,1,opt,name=processID,proto3" json:"processID,omitempty"`
	Command   ProcessControlRequest_Command `protobuf:"varint,2,opt,name=command,proto3,enum=xbus.control.ProcessControlRequest_Command" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessControlRequest) Descriptor deprecated 

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

Deprecated: Use ProcessControlRequest.ProtoReflect.Descriptor instead.

func (*ProcessControlRequest) GetCommand 

func (x *ProcessControlRequest) GetCommand() ProcessControlRequest_Command

func (*ProcessControlRequest) GetProcessID 

func (x *ProcessControlRequest) GetProcessID() []byte

func (*ProcessControlRequest) GetProcessIDAsUUID 

func (x *ProcessControlRequest) GetProcessIDAsUUID() api.UUID

func (*ProcessControlRequest) ProtoMessage 

func (*ProcessControlRequest) ProtoMessage()

func (*ProcessControlRequest) ProtoReflect 

func (x *ProcessControlRequest) ProtoReflect() protoreflect.Message

func (*ProcessControlRequest) Reset 

func (x *ProcessControlRequest) Reset()

func (*ProcessControlRequest) String 

func (x *ProcessControlRequest) String() string

type ProcessControlRequest_Command 

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

func (ProcessControlRequest_Command) Descriptor 

func (ProcessControlRequest_Command) Descriptor() protoreflect.EnumDescriptor

func (ProcessControlRequest_Command) Enum 

func (x ProcessControlRequest_Command) Enum() *ProcessControlRequest_Command

func (ProcessControlRequest_Command) EnumDescriptor deprecated 

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

Deprecated: Use ProcessControlRequest_Command.Descriptor instead.

func (ProcessControlRequest_Command) Number 

func (x ProcessControlRequest_Command) Number() protoreflect.EnumNumber

func (ProcessControlRequest_Command) String 

func (x ProcessControlRequest_Command) String() string

func (ProcessControlRequest_Command) Type 

func (ProcessControlRequest_Command) Type() protoreflect.EnumType

type ProcessExportReply 

type ProcessExportReply struct {
	ProcessList []string `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessExportReply) Descriptor deprecated 

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

Deprecated: Use ProcessExportReply.ProtoReflect.Descriptor instead.

func (*ProcessExportReply) GetProcessList 

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

func (*ProcessExportReply) ProtoMessage 

func (*ProcessExportReply) ProtoMessage()

func (*ProcessExportReply) ProtoReflect 

func (x *ProcessExportReply) ProtoReflect() protoreflect.Message

func (*ProcessExportReply) Reset 

func (x *ProcessExportReply) Reset()

func (*ProcessExportReply) String 

func (x *ProcessExportReply) String() string

type ProcessExportRequest 

type ProcessExportRequest struct {
	ProcessIDs        [][]byte     `protobuf:"bytes,1,rep,name=processIDs,proto3" json:"processIDs,omitempty"`
	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"`
	// contains filtered or unexported fields
}

func (*ProcessExportRequest) Descriptor deprecated 

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

Deprecated: Use ProcessExportRequest.ProtoReflect.Descriptor instead.

func (*ProcessExportRequest) GetEnvelopeSizeLimit 

func (x *ProcessExportRequest) GetEnvelopeSizeLimit() int64

func (*ProcessExportRequest) GetExportEnvelope 

func (x *ProcessExportRequest) GetExportEnvelope() bool

func (*ProcessExportRequest) GetExportFull 

func (x *ProcessExportRequest) GetExportFull() bool

func (*ProcessExportRequest) GetExportJobs 

func (x *ProcessExportRequest) GetExportJobs() bool

func (*ProcessExportRequest) GetExportLogs 

func (x *ProcessExportRequest) GetExportLogs() bool

func (*ProcessExportRequest) GetExportProcessLogs 

func (x *ProcessExportRequest) GetExportProcessLogs() bool

func (*ProcessExportRequest) GetLogLevel 

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

func (*ProcessExportRequest) GetProcessIDs 

func (x *ProcessExportRequest) GetProcessIDs() [][]byte

func (*ProcessExportRequest) GetProcessIDsAsUUIDSlice 

func (x *ProcessExportRequest) GetProcessIDsAsUUIDSlice() api.UUIDSlice

func (*ProcessExportRequest) ProtoMessage 

func (*ProcessExportRequest) ProtoMessage()

func (*ProcessExportRequest) ProtoReflect 

func (x *ProcessExportRequest) ProtoReflect() protoreflect.Message

func (*ProcessExportRequest) Reset 

func (x *ProcessExportRequest) Reset()

func (*ProcessExportRequest) String 

func (x *ProcessExportRequest) String() string

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 [][]byte `protobuf:"bytes,1,rep,name=processIDs,proto3" json:"processIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessPurgeRequest) Descriptor deprecated 

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

Deprecated: Use ProcessPurgeRequest.ProtoReflect.Descriptor instead.

func (*ProcessPurgeRequest) GetProcessIDs 

func (x *ProcessPurgeRequest) GetProcessIDs() [][]byte

func (*ProcessPurgeRequest) GetProcessIDsAsUUIDSlice 

func (x *ProcessPurgeRequest) GetProcessIDsAsUUIDSlice() api.UUIDSlice

func (*ProcessPurgeRequest) ProtoMessage 

func (*ProcessPurgeRequest) ProtoMessage()

func (*ProcessPurgeRequest) ProtoReflect 

func (x *ProcessPurgeRequest) ProtoReflect() protoreflect.Message

func (*ProcessPurgeRequest) Reset 

func (x *ProcessPurgeRequest) Reset()

func (*ProcessPurgeRequest) String 

func (x *ProcessPurgeRequest) String() string

type ProcessQueryReply 

type ProcessQueryReply struct {
	ProcessList []*api.Process `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessQueryReply) Descriptor deprecated 

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

Deprecated: Use ProcessQueryReply.ProtoReflect.Descriptor instead.

func (*ProcessQueryReply) GetProcessList 

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

func (*ProcessQueryReply) ProtoMessage 

func (*ProcessQueryReply) ProtoMessage()

func (*ProcessQueryReply) ProtoReflect 

func (x *ProcessQueryReply) ProtoReflect() protoreflect.Message

func (*ProcessQueryReply) Reset 

func (x *ProcessQueryReply) Reset()

func (*ProcessQueryReply) String 

func (x *ProcessQueryReply) String() string

type ProcessQueryRequest 

type ProcessQueryRequest struct {
	Filter *api.ProcessFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessQueryRequest) Descriptor deprecated 

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

Deprecated: Use ProcessQueryRequest.ProtoReflect.Descriptor instead.

func (*ProcessQueryRequest) GetFilter 

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

func (*ProcessQueryRequest) ProtoMessage 

func (*ProcessQueryRequest) ProtoMessage()

func (*ProcessQueryRequest) ProtoReflect 

func (x *ProcessQueryRequest) ProtoReflect() protoreflect.Message

func (*ProcessQueryRequest) Reset 

func (x *ProcessQueryRequest) Reset()

func (*ProcessQueryRequest) String 

func (x *ProcessQueryRequest) String() string

type ProcessReplayRequest 

type ProcessReplayRequest struct {
	Process *api.Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	Match   bool         `protobuf:"varint,2,opt,name=match,proto3" json:"match,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessReplayRequest) Descriptor deprecated 

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

Deprecated: Use ProcessReplayRequest.ProtoReflect.Descriptor instead.

func (*ProcessReplayRequest) GetMatch 

func (x *ProcessReplayRequest) GetMatch() bool

func (*ProcessReplayRequest) GetProcess 

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

func (*ProcessReplayRequest) ProtoMessage 

func (*ProcessReplayRequest) ProtoMessage()

func (*ProcessReplayRequest) ProtoReflect 

func (x *ProcessReplayRequest) ProtoReflect() protoreflect.Message

func (*ProcessReplayRequest) Reset 

func (x *ProcessReplayRequest) Reset()

func (*ProcessReplayRequest) String 

func (x *ProcessReplayRequest) String() string

type ProcessServer 

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

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

type ProcessSummary 

type ProcessSummary struct {
	Entries []*ProcessSummary_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessSummary) Descriptor deprecated 

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

Deprecated: Use ProcessSummary.ProtoReflect.Descriptor instead.

func (*ProcessSummary) GetEntries 

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

func (*ProcessSummary) ProtoMessage 

func (*ProcessSummary) ProtoMessage()

func (*ProcessSummary) ProtoReflect 

func (x *ProcessSummary) ProtoReflect() protoreflect.Message

func (*ProcessSummary) Reset 

func (x *ProcessSummary) Reset()

func (*ProcessSummary) String 

func (x *ProcessSummary) String() string

type ProcessSummary_Entry 

type ProcessSummary_Entry struct {
	PipelineID  []byte             `protobuf:"bytes,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	EmitterID   []byte             `protobuf:"bytes,2,opt,name=emitterID,proto3" json:"emitterID,omitempty"`
	Status      api.Process_Status `protobuf:"varint,3,opt,name=status,proto3,enum=xbus.Process_Status" json:"status,omitempty"`
	ResultAcked bool               `protobuf:"varint,4,opt,name=resultAcked,proto3" json:"resultAcked,omitempty"`
	Count       uint64             `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessSummary_Entry) Descriptor deprecated 

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

Deprecated: Use ProcessSummary_Entry.ProtoReflect.Descriptor instead.

func (*ProcessSummary_Entry) GetCount 

func (x *ProcessSummary_Entry) GetCount() uint64

func (*ProcessSummary_Entry) GetEmitterID 

func (x *ProcessSummary_Entry) GetEmitterID() []byte

func (*ProcessSummary_Entry) GetEmitterIDAsUUID 

func (x *ProcessSummary_Entry) GetEmitterIDAsUUID() api.UUID

func (*ProcessSummary_Entry) GetPipelineID 

func (x *ProcessSummary_Entry) GetPipelineID() []byte

func (*ProcessSummary_Entry) GetPipelineIDAsUUID 

func (x *ProcessSummary_Entry) GetPipelineIDAsUUID() api.UUID

func (*ProcessSummary_Entry) GetResultAcked 

func (x *ProcessSummary_Entry) GetResultAcked() bool

func (*ProcessSummary_Entry) GetStatus 

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

func (*ProcessSummary_Entry) ProtoMessage 

func (*ProcessSummary_Entry) ProtoMessage()

func (*ProcessSummary_Entry) ProtoReflect 

func (x *ProcessSummary_Entry) ProtoReflect() protoreflect.Message

func (*ProcessSummary_Entry) Reset 

func (x *ProcessSummary_Entry) Reset()

func (*ProcessSummary_Entry) String 

func (x *ProcessSummary_Entry) String() string

type StorageStat 

type StorageStat struct {
	Entries []*StorageStat_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageStat) Descriptor deprecated 

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

Deprecated: Use StorageStat.ProtoReflect.Descriptor instead.

func (*StorageStat) GetEntries 

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

func (*StorageStat) ProtoMessage 

func (*StorageStat) ProtoMessage()

func (*StorageStat) ProtoReflect 

func (x *StorageStat) ProtoReflect() protoreflect.Message

func (*StorageStat) Reset 

func (x *StorageStat) Reset()

func (*StorageStat) String 

func (x *StorageStat) String() string

type StorageStat_Entry 

type StorageStat_Entry struct {
	Name           string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type           StorageType `protobuf:"varint,2,opt,name=type,proto3,enum=xbus.control.StorageType" json:"type,omitempty"`
	Implementation string      `protobuf:"bytes,3,opt,name=implementation,proto3" json:"implementation,omitempty"`
	Count          uint64      `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	EstimatedSize  uint64      `protobuf:"varint,5,opt,name=estimatedSize,proto3" json:"estimatedSize,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageStat_Entry) Descriptor deprecated 

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

Deprecated: Use StorageStat_Entry.ProtoReflect.Descriptor instead.

func (*StorageStat_Entry) GetCount 

func (x *StorageStat_Entry) GetCount() uint64

func (*StorageStat_Entry) GetEstimatedSize 

func (x *StorageStat_Entry) GetEstimatedSize() uint64

func (*StorageStat_Entry) GetImplementation 

func (x *StorageStat_Entry) GetImplementation() string

func (*StorageStat_Entry) GetName 

func (x *StorageStat_Entry) GetName() string

func (*StorageStat_Entry) GetType 

func (x *StorageStat_Entry) GetType() StorageType

func (*StorageStat_Entry) ProtoMessage 

func (*StorageStat_Entry) ProtoMessage()

func (*StorageStat_Entry) ProtoReflect 

func (x *StorageStat_Entry) ProtoReflect() protoreflect.Message

func (*StorageStat_Entry) Reset 

func (x *StorageStat_Entry) Reset()

func (*StorageStat_Entry) String 

func (x *StorageStat_Entry) String() string

type StorageType 

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

func (StorageType) Descriptor 

func (StorageType) Descriptor() protoreflect.EnumDescriptor

func (StorageType) Enum 

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated 

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) Number 

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String 

func (x StorageType) String() string

func (StorageType) Type 

func (StorageType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*TaskProgress) Descriptor deprecated 

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

Deprecated: Use TaskProgress.ProtoReflect.Descriptor instead.

func (*TaskProgress) GetMaxProgression 

func (x *TaskProgress) GetMaxProgression() uint32

func (*TaskProgress) GetMessage 

func (x *TaskProgress) GetMessage() string

func (*TaskProgress) GetProgression 

func (x *TaskProgress) GetProgression() uint32

func (*TaskProgress) ProtoMessage 

func (*TaskProgress) ProtoMessage()

func (*TaskProgress) ProtoReflect 

func (x *TaskProgress) ProtoReflect() protoreflect.Message

func (*TaskProgress) Reset 

func (x *TaskProgress) Reset()

func (*TaskProgress) String 

func (x *TaskProgress) String() string

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.