Documentation ¶
Overview ¶
This code was autogenerated from xbus/control.proto, do not edit.
Index ¶
- Variables
- type AccountClient
- func (c *AccountClient) Delete(req AccountIDRequest) (err error)
- func (c *AccountClient) GetAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
- func (c *AccountClient) List(req AccountListRequest) (resp AccountListReply, err error)
- func (c *AccountClient) PasswordSet(req AccountPasswordSetRequest) (err error)
- func (c *AccountClient) RenewAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
- func (c *AccountClient) ResetCert(req AccountIDRequest) (err error)
- func (c *AccountClient) SetAPIKey(req AccountUpdateRequest) (resp xbus_io_go_xbus_api.Account, err error)
- func (c *AccountClient) Update(req AccountUpdateRequest) (resp xbus_io_go_xbus_api.Account, err error)
- type AccountHandler
- type AccountIDRequest
- func (*AccountIDRequest) Descriptor() ([]byte, []int)
- func (this *AccountIDRequest) Equal(that interface{}) bool
- func (this *AccountIDRequest) GoString() string
- func (m *AccountIDRequest) Marshal() (dAtA []byte, err error)
- func (m *AccountIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountIDRequest) ProtoMessage()
- func (m *AccountIDRequest) Reset()
- func (m *AccountIDRequest) Size() (n int)
- func (this *AccountIDRequest) String() string
- func (m *AccountIDRequest) Unmarshal(dAtA []byte) error
- func (this *AccountIDRequest) VerboseEqual(that interface{}) error
- func (m *AccountIDRequest) XXX_DiscardUnknown()
- func (m *AccountIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountIDRequest) XXX_Merge(src proto.Message)
- func (m *AccountIDRequest) XXX_Size() int
- func (m *AccountIDRequest) XXX_Unmarshal(b []byte) error
- type AccountListReply
- func (*AccountListReply) Descriptor() ([]byte, []int)
- func (this *AccountListReply) Equal(that interface{}) bool
- func (m *AccountListReply) GetAccountList() []api.Account
- func (this *AccountListReply) GoString() string
- func (m *AccountListReply) Marshal() (dAtA []byte, err error)
- func (m *AccountListReply) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountListReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountListReply) ProtoMessage()
- func (m *AccountListReply) Reset()
- func (m *AccountListReply) Size() (n int)
- func (this *AccountListReply) String() string
- func (m *AccountListReply) Unmarshal(dAtA []byte) error
- func (this *AccountListReply) VerboseEqual(that interface{}) error
- func (m *AccountListReply) XXX_DiscardUnknown()
- func (m *AccountListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountListReply) XXX_Merge(src proto.Message)
- func (m *AccountListReply) XXX_Size() int
- func (m *AccountListReply) XXX_Unmarshal(b []byte) error
- type AccountListRequest
- func (*AccountListRequest) Descriptor() ([]byte, []int)
- func (this *AccountListRequest) Equal(that interface{}) bool
- func (this *AccountListRequest) GoString() string
- func (m *AccountListRequest) Marshal() (dAtA []byte, err error)
- func (m *AccountListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountListRequest) ProtoMessage()
- func (m *AccountListRequest) Reset()
- func (m *AccountListRequest) Size() (n int)
- func (this *AccountListRequest) String() string
- func (m *AccountListRequest) Unmarshal(dAtA []byte) error
- func (this *AccountListRequest) VerboseEqual(that interface{}) error
- func (m *AccountListRequest) XXX_DiscardUnknown()
- func (m *AccountListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountListRequest) XXX_Merge(src proto.Message)
- func (m *AccountListRequest) XXX_Size() int
- func (m *AccountListRequest) XXX_Unmarshal(b []byte) error
- type AccountPasswordSetRequest
- func (*AccountPasswordSetRequest) Descriptor() ([]byte, []int)
- func (this *AccountPasswordSetRequest) Equal(that interface{}) bool
- func (m *AccountPasswordSetRequest) GetPassword() string
- func (this *AccountPasswordSetRequest) GoString() string
- func (m *AccountPasswordSetRequest) Marshal() (dAtA []byte, err error)
- func (m *AccountPasswordSetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountPasswordSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountPasswordSetRequest) ProtoMessage()
- func (m *AccountPasswordSetRequest) Reset()
- func (m *AccountPasswordSetRequest) Size() (n int)
- func (this *AccountPasswordSetRequest) String() string
- func (m *AccountPasswordSetRequest) Unmarshal(dAtA []byte) error
- func (this *AccountPasswordSetRequest) VerboseEqual(that interface{}) error
- func (m *AccountPasswordSetRequest) XXX_DiscardUnknown()
- func (m *AccountPasswordSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountPasswordSetRequest) XXX_Merge(src proto.Message)
- func (m *AccountPasswordSetRequest) XXX_Size() int
- func (m *AccountPasswordSetRequest) XXX_Unmarshal(b []byte) error
- type AccountServer
- type AccountUpdateRequest
- func (*AccountUpdateRequest) Descriptor() ([]byte, []int)
- func (this *AccountUpdateRequest) Equal(that interface{}) bool
- func (m *AccountUpdateRequest) GetAccount() api.Account
- func (m *AccountUpdateRequest) GetExpire() time.Time
- func (this *AccountUpdateRequest) GoString() string
- func (m *AccountUpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *AccountUpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountUpdateRequest) ProtoMessage()
- func (m *AccountUpdateRequest) Reset()
- func (m *AccountUpdateRequest) Size() (n int)
- func (this *AccountUpdateRequest) String() string
- func (m *AccountUpdateRequest) Unmarshal(dAtA []byte) error
- func (this *AccountUpdateRequest) VerboseEqual(that interface{}) error
- func (m *AccountUpdateRequest) XXX_DiscardUnknown()
- func (m *AccountUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountUpdateRequest) XXX_Merge(src proto.Message)
- func (m *AccountUpdateRequest) XXX_Size() int
- func (m *AccountUpdateRequest) XXX_Unmarshal(b []byte) error
- type ActorClient
- func (c *ActorClient) Create(req ActorRequest) (resp ActorReply, err error)
- func (c *ActorClient) Delete(req ActorRequest) (resp ActorReply, err error)
- func (c *ActorClient) Query(req ActorRequest) (resp ActorReply, err error)
- func (c *ActorClient) Update(req ActorRequest) (resp ActorReply, err error)
- type ActorHandler
- type ActorReply
- func (*ActorReply) Descriptor() ([]byte, []int)
- func (this *ActorReply) Equal(that interface{}) bool
- func (m *ActorReply) GetActorList() []api.Actor
- func (this *ActorReply) GoString() string
- func (m *ActorReply) Marshal() (dAtA []byte, err error)
- func (m *ActorReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorReply) ProtoMessage()
- func (m *ActorReply) Reset()
- func (m *ActorReply) Size() (n int)
- func (this *ActorReply) String() string
- func (m *ActorReply) Unmarshal(dAtA []byte) error
- func (this *ActorReply) VerboseEqual(that interface{}) error
- func (m *ActorReply) XXX_DiscardUnknown()
- func (m *ActorReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorReply) XXX_Merge(src proto.Message)
- func (m *ActorReply) XXX_Size() int
- func (m *ActorReply) XXX_Unmarshal(b []byte) error
- type ActorRequest
- func (*ActorRequest) Descriptor() ([]byte, []int)
- func (this *ActorRequest) Equal(that interface{}) bool
- func (m *ActorRequest) GetActorList() []api.Actor
- func (this *ActorRequest) GoString() string
- func (m *ActorRequest) Marshal() (dAtA []byte, err error)
- func (m *ActorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActorRequest) ProtoMessage()
- func (m *ActorRequest) Reset()
- func (m *ActorRequest) Size() (n int)
- func (this *ActorRequest) String() string
- func (m *ActorRequest) Unmarshal(dAtA []byte) error
- func (this *ActorRequest) VerboseEqual(that interface{}) error
- func (m *ActorRequest) XXX_DiscardUnknown()
- func (m *ActorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorRequest) XXX_Merge(src proto.Message)
- func (m *ActorRequest) XXX_Size() int
- func (m *ActorRequest) XXX_Unmarshal(b []byte) error
- type ActorServer
- type Client
- type EnvelopeClient
- type EnvelopeHandler
- type EnvelopeServer
- type LogsClient
- type LogsHandler
- type LogsPurgeReply
- func (*LogsPurgeReply) Descriptor() ([]byte, []int)
- func (this *LogsPurgeReply) Equal(that interface{}) bool
- func (m *LogsPurgeReply) GetCount() int64
- func (this *LogsPurgeReply) GoString() string
- func (m *LogsPurgeReply) Marshal() (dAtA []byte, err error)
- func (m *LogsPurgeReply) MarshalTo(dAtA []byte) (int, error)
- func (m *LogsPurgeReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogsPurgeReply) ProtoMessage()
- func (m *LogsPurgeReply) Reset()
- func (m *LogsPurgeReply) Size() (n int)
- func (this *LogsPurgeReply) String() string
- func (m *LogsPurgeReply) Unmarshal(dAtA []byte) error
- func (this *LogsPurgeReply) VerboseEqual(that interface{}) error
- func (m *LogsPurgeReply) XXX_DiscardUnknown()
- func (m *LogsPurgeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogsPurgeReply) XXX_Merge(src proto.Message)
- func (m *LogsPurgeReply) XXX_Size() int
- func (m *LogsPurgeReply) XXX_Unmarshal(b []byte) error
- type LogsPurgeRequest
- func (*LogsPurgeRequest) Descriptor() ([]byte, []int)
- func (this *LogsPurgeRequest) Equal(that interface{}) bool
- func (m *LogsPurgeRequest) GetBefore() time.Time
- func (this *LogsPurgeRequest) GoString() string
- func (m *LogsPurgeRequest) Marshal() (dAtA []byte, err error)
- func (m *LogsPurgeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LogsPurgeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogsPurgeRequest) ProtoMessage()
- func (m *LogsPurgeRequest) Reset()
- func (m *LogsPurgeRequest) Size() (n int)
- func (this *LogsPurgeRequest) String() string
- func (m *LogsPurgeRequest) Unmarshal(dAtA []byte) error
- func (this *LogsPurgeRequest) VerboseEqual(that interface{}) error
- func (m *LogsPurgeRequest) XXX_DiscardUnknown()
- func (m *LogsPurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogsPurgeRequest) XXX_Merge(src proto.Message)
- func (m *LogsPurgeRequest) XXX_Size() int
- func (m *LogsPurgeRequest) XXX_Unmarshal(b []byte) error
- type LogsServer
- type OctetStreamList
- func (*OctetStreamList) Descriptor() ([]byte, []int)
- func (this *OctetStreamList) Equal(that interface{}) bool
- func (m *OctetStreamList) GetChunks() []OctetStreamList_Chunk
- func (m *OctetStreamList) GetMaxProgression() int64
- func (m *OctetStreamList) GetProgression() int64
- func (this *OctetStreamList) GoString() string
- func (m *OctetStreamList) Marshal() (dAtA []byte, err error)
- func (m *OctetStreamList) MarshalTo(dAtA []byte) (int, error)
- func (m *OctetStreamList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OctetStreamList) ProtoMessage()
- func (m *OctetStreamList) Reset()
- func (m *OctetStreamList) Size() (n int)
- func (this *OctetStreamList) String() string
- func (m *OctetStreamList) Unmarshal(dAtA []byte) error
- func (this *OctetStreamList) VerboseEqual(that interface{}) error
- func (m *OctetStreamList) XXX_DiscardUnknown()
- func (m *OctetStreamList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OctetStreamList) XXX_Merge(src proto.Message)
- func (m *OctetStreamList) XXX_Size() int
- func (m *OctetStreamList) XXX_Unmarshal(b []byte) error
- type OctetStreamList_Chunk
- func (*OctetStreamList_Chunk) Descriptor() ([]byte, []int)
- func (this *OctetStreamList_Chunk) Equal(that interface{}) bool
- func (m *OctetStreamList_Chunk) GetData() []byte
- func (m *OctetStreamList_Chunk) GetIndex() int64
- func (this *OctetStreamList_Chunk) GoString() string
- func (m *OctetStreamList_Chunk) Marshal() (dAtA []byte, err error)
- func (m *OctetStreamList_Chunk) MarshalTo(dAtA []byte) (int, error)
- func (m *OctetStreamList_Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OctetStreamList_Chunk) ProtoMessage()
- func (m *OctetStreamList_Chunk) Reset()
- func (m *OctetStreamList_Chunk) Size() (n int)
- func (this *OctetStreamList_Chunk) String() string
- func (m *OctetStreamList_Chunk) Unmarshal(dAtA []byte) error
- func (this *OctetStreamList_Chunk) VerboseEqual(that interface{}) error
- func (m *OctetStreamList_Chunk) XXX_DiscardUnknown()
- func (m *OctetStreamList_Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OctetStreamList_Chunk) XXX_Merge(src proto.Message)
- func (m *OctetStreamList_Chunk) XXX_Size() int
- func (m *OctetStreamList_Chunk) XXX_Unmarshal(b []byte) error
- type PMProcessClient
- type PMProcessHandler
- type PMProcessQueryReply
- func (*PMProcessQueryReply) Descriptor() ([]byte, []int)
- func (this *PMProcessQueryReply) Equal(that interface{}) bool
- func (m *PMProcessQueryReply) GetPMProcessList() []api.PMProcess
- func (this *PMProcessQueryReply) GoString() string
- func (m *PMProcessQueryReply) Marshal() (dAtA []byte, err error)
- func (m *PMProcessQueryReply) MarshalTo(dAtA []byte) (int, error)
- func (m *PMProcessQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PMProcessQueryReply) ProtoMessage()
- func (m *PMProcessQueryReply) Reset()
- func (m *PMProcessQueryReply) Size() (n int)
- func (this *PMProcessQueryReply) String() string
- func (m *PMProcessQueryReply) Unmarshal(dAtA []byte) error
- func (this *PMProcessQueryReply) VerboseEqual(that interface{}) error
- func (m *PMProcessQueryReply) XXX_DiscardUnknown()
- func (m *PMProcessQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PMProcessQueryReply) XXX_Merge(src proto.Message)
- func (m *PMProcessQueryReply) XXX_Size() int
- func (m *PMProcessQueryReply) XXX_Unmarshal(b []byte) error
- type PMProcessQueryRequest
- func (*PMProcessQueryRequest) Descriptor() ([]byte, []int)
- func (this *PMProcessQueryRequest) Equal(that interface{}) bool
- func (m *PMProcessQueryRequest) GetIncludeClosed() bool
- func (m *PMProcessQueryRequest) GetLevel() api.LogLevel
- func (m *PMProcessQueryRequest) GetReturnLogs() bool
- func (this *PMProcessQueryRequest) GoString() string
- func (m *PMProcessQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *PMProcessQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PMProcessQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PMProcessQueryRequest) ProtoMessage()
- func (m *PMProcessQueryRequest) Reset()
- func (m *PMProcessQueryRequest) Size() (n int)
- func (this *PMProcessQueryRequest) String() string
- func (m *PMProcessQueryRequest) Unmarshal(dAtA []byte) error
- func (this *PMProcessQueryRequest) VerboseEqual(that interface{}) error
- func (m *PMProcessQueryRequest) XXX_DiscardUnknown()
- func (m *PMProcessQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PMProcessQueryRequest) XXX_Merge(src proto.Message)
- func (m *PMProcessQueryRequest) XXX_Size() int
- func (m *PMProcessQueryRequest) XXX_Unmarshal(b []byte) error
- type PMProcessServer
- type PMProcessSetStatusRequest
- func (*PMProcessSetStatusRequest) Descriptor() ([]byte, []int)
- func (this *PMProcessSetStatusRequest) Equal(that interface{}) bool
- func (m *PMProcessSetStatusRequest) GetComment() string
- func (m *PMProcessSetStatusRequest) GetStatus() api.PMProcess_Status
- func (this *PMProcessSetStatusRequest) GoString() string
- func (m *PMProcessSetStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *PMProcessSetStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PMProcessSetStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PMProcessSetStatusRequest) ProtoMessage()
- func (m *PMProcessSetStatusRequest) Reset()
- func (m *PMProcessSetStatusRequest) Size() (n int)
- func (this *PMProcessSetStatusRequest) String() string
- func (m *PMProcessSetStatusRequest) Unmarshal(dAtA []byte) error
- func (this *PMProcessSetStatusRequest) VerboseEqual(that interface{}) error
- func (m *PMProcessSetStatusRequest) XXX_DiscardUnknown()
- func (m *PMProcessSetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PMProcessSetStatusRequest) XXX_Merge(src proto.Message)
- func (m *PMProcessSetStatusRequest) XXX_Size() int
- func (m *PMProcessSetStatusRequest) XXX_Unmarshal(b []byte) error
- type PipelineClient
- func (c *PipelineClient) GetGraph(req xbus_io_go_xbus_api.PipelineInfo) (resp xbus_io_go_xbus_api.StringReply, err error)
- func (c *PipelineClient) Query(req PipelineQueryRequest) (resp PipelineQueryReply, err error)
- func (c *PipelineClient) Save(req PipelineSaveRequest) (resp PipelineSaveReply, err error)
- func (c *PipelineClient) SetStatus(req xbus_io_go_xbus_api.PipelineInfo) (resp PipelineSetStatusReply, err error)
- type PipelineHandler
- type PipelineQueryReply
- func (*PipelineQueryReply) Descriptor() ([]byte, []int)
- func (this *PipelineQueryReply) Equal(that interface{}) bool
- func (m *PipelineQueryReply) GetPipelineList() []api.PipelineInfo
- func (this *PipelineQueryReply) GoString() string
- func (m *PipelineQueryReply) Marshal() (dAtA []byte, err error)
- func (m *PipelineQueryReply) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineQueryReply) ProtoMessage()
- func (m *PipelineQueryReply) Reset()
- func (m *PipelineQueryReply) Size() (n int)
- func (this *PipelineQueryReply) String() string
- func (m *PipelineQueryReply) Unmarshal(dAtA []byte) error
- func (this *PipelineQueryReply) VerboseEqual(that interface{}) error
- func (m *PipelineQueryReply) XXX_DiscardUnknown()
- func (m *PipelineQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineQueryReply) XXX_Merge(src proto.Message)
- func (m *PipelineQueryReply) XXX_Size() int
- func (m *PipelineQueryReply) XXX_Unmarshal(b []byte) error
- type PipelineQueryRequest
- func (*PipelineQueryRequest) Descriptor() ([]byte, []int)
- func (this *PipelineQueryRequest) Equal(that interface{}) bool
- func (m *PipelineQueryRequest) GetName() string
- func (this *PipelineQueryRequest) GoString() string
- func (m *PipelineQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *PipelineQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineQueryRequest) ProtoMessage()
- func (m *PipelineQueryRequest) Reset()
- func (m *PipelineQueryRequest) Size() (n int)
- func (this *PipelineQueryRequest) String() string
- func (m *PipelineQueryRequest) Unmarshal(dAtA []byte) error
- func (this *PipelineQueryRequest) VerboseEqual(that interface{}) error
- func (m *PipelineQueryRequest) XXX_DiscardUnknown()
- func (m *PipelineQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineQueryRequest) XXX_Merge(src proto.Message)
- func (m *PipelineQueryRequest) XXX_Size() int
- func (m *PipelineQueryRequest) XXX_Unmarshal(b []byte) error
- type PipelineSaveReply
- func (*PipelineSaveReply) Descriptor() ([]byte, []int)
- func (this *PipelineSaveReply) Equal(that interface{}) bool
- func (m *PipelineSaveReply) GetGraph() string
- func (m *PipelineSaveReply) GetInfo() api.PipelineInfo
- func (m *PipelineSaveReply) GetIsValid() bool
- func (m *PipelineSaveReply) GetValidationMessages() []string
- func (this *PipelineSaveReply) GoString() string
- func (m *PipelineSaveReply) Marshal() (dAtA []byte, err error)
- func (m *PipelineSaveReply) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineSaveReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineSaveReply) ProtoMessage()
- func (m *PipelineSaveReply) Reset()
- func (m *PipelineSaveReply) Size() (n int)
- func (this *PipelineSaveReply) String() string
- func (m *PipelineSaveReply) Unmarshal(dAtA []byte) error
- func (this *PipelineSaveReply) VerboseEqual(that interface{}) error
- func (m *PipelineSaveReply) XXX_DiscardUnknown()
- func (m *PipelineSaveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineSaveReply) XXX_Merge(src proto.Message)
- func (m *PipelineSaveReply) XXX_Size() int
- func (m *PipelineSaveReply) XXX_Unmarshal(b []byte) error
- type PipelineSaveRequest
- func (*PipelineSaveRequest) Descriptor() ([]byte, []int)
- func (this *PipelineSaveRequest) Equal(that interface{}) bool
- func (m *PipelineSaveRequest) GetGraph() string
- func (m *PipelineSaveRequest) GetInfo() api.PipelineInfo
- func (this *PipelineSaveRequest) GoString() string
- func (m *PipelineSaveRequest) Marshal() (dAtA []byte, err error)
- func (m *PipelineSaveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineSaveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineSaveRequest) ProtoMessage()
- func (m *PipelineSaveRequest) Reset()
- func (m *PipelineSaveRequest) Size() (n int)
- func (this *PipelineSaveRequest) String() string
- func (m *PipelineSaveRequest) Unmarshal(dAtA []byte) error
- func (this *PipelineSaveRequest) VerboseEqual(that interface{}) error
- func (m *PipelineSaveRequest) XXX_DiscardUnknown()
- func (m *PipelineSaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineSaveRequest) XXX_Merge(src proto.Message)
- func (m *PipelineSaveRequest) XXX_Size() int
- func (m *PipelineSaveRequest) XXX_Unmarshal(b []byte) error
- type PipelineServer
- type PipelineSetStatusReply
- func (*PipelineSetStatusReply) Descriptor() ([]byte, []int)
- func (this *PipelineSetStatusReply) Equal(that interface{}) bool
- func (m *PipelineSetStatusReply) GetInfo() api.PipelineInfo
- func (m *PipelineSetStatusReply) GetIsValid() bool
- func (m *PipelineSetStatusReply) GetValidationMessages() []string
- func (this *PipelineSetStatusReply) GoString() string
- func (m *PipelineSetStatusReply) Marshal() (dAtA []byte, err error)
- func (m *PipelineSetStatusReply) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineSetStatusReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineSetStatusReply) ProtoMessage()
- func (m *PipelineSetStatusReply) Reset()
- func (m *PipelineSetStatusReply) Size() (n int)
- func (this *PipelineSetStatusReply) String() string
- func (m *PipelineSetStatusReply) Unmarshal(dAtA []byte) error
- func (this *PipelineSetStatusReply) VerboseEqual(that interface{}) error
- func (m *PipelineSetStatusReply) XXX_DiscardUnknown()
- func (m *PipelineSetStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineSetStatusReply) XXX_Merge(src proto.Message)
- func (m *PipelineSetStatusReply) XXX_Size() int
- func (m *PipelineSetStatusReply) XXX_Unmarshal(b []byte) error
- type ProcessClient
- func (c *ProcessClient) Control(req ProcessControlRequest) (err error)
- func (c *ProcessClient) Export(req ProcessExportRequest) (resp ProcessExportReply, err error)
- func (c *ProcessClient) ExportStream(ctx context.Context, req ProcessExportRequest, ...) error
- func (c *ProcessClient) Purge(ctx context.Context, req ProcessPurgeRequest, ...) error
- func (c *ProcessClient) Query(ctx context.Context, req ProcessQueryRequest, ...) error
- type ProcessControlRequest
- func (*ProcessControlRequest) Descriptor() ([]byte, []int)
- func (this *ProcessControlRequest) Equal(that interface{}) bool
- func (m *ProcessControlRequest) GetCommand() ProcessControlRequest_Command
- func (this *ProcessControlRequest) GoString() string
- func (m *ProcessControlRequest) Marshal() (dAtA []byte, err error)
- func (m *ProcessControlRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessControlRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessControlRequest) ProtoMessage()
- func (m *ProcessControlRequest) Reset()
- func (m *ProcessControlRequest) Size() (n int)
- func (this *ProcessControlRequest) String() string
- func (m *ProcessControlRequest) Unmarshal(dAtA []byte) error
- func (this *ProcessControlRequest) VerboseEqual(that interface{}) error
- func (m *ProcessControlRequest) XXX_DiscardUnknown()
- func (m *ProcessControlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessControlRequest) XXX_Merge(src proto.Message)
- func (m *ProcessControlRequest) XXX_Size() int
- func (m *ProcessControlRequest) XXX_Unmarshal(b []byte) error
- type ProcessControlRequest_Command
- type ProcessExportReply
- func (*ProcessExportReply) Descriptor() ([]byte, []int)
- func (this *ProcessExportReply) Equal(that interface{}) bool
- func (m *ProcessExportReply) GetProcessList() []string
- func (this *ProcessExportReply) GoString() string
- func (m *ProcessExportReply) Marshal() (dAtA []byte, err error)
- func (m *ProcessExportReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessExportReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessExportReply) ProtoMessage()
- func (m *ProcessExportReply) Reset()
- func (m *ProcessExportReply) Size() (n int)
- func (this *ProcessExportReply) String() string
- func (m *ProcessExportReply) Unmarshal(dAtA []byte) error
- func (this *ProcessExportReply) VerboseEqual(that interface{}) error
- func (m *ProcessExportReply) XXX_DiscardUnknown()
- func (m *ProcessExportReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessExportReply) XXX_Merge(src proto.Message)
- func (m *ProcessExportReply) XXX_Size() int
- func (m *ProcessExportReply) XXX_Unmarshal(b []byte) error
- type ProcessExportRequest
- func (*ProcessExportRequest) Descriptor() ([]byte, []int)
- func (this *ProcessExportRequest) Equal(that interface{}) bool
- func (m *ProcessExportRequest) GetEnvelopeSizeLimit() int64
- func (m *ProcessExportRequest) GetExportEnvelope() bool
- func (m *ProcessExportRequest) GetExportFull() bool
- func (m *ProcessExportRequest) GetExportJobs() bool
- func (m *ProcessExportRequest) GetExportLogs() bool
- func (m *ProcessExportRequest) GetExportProcessLogs() bool
- func (m *ProcessExportRequest) GetLogLevel() api.LogLevel
- func (this *ProcessExportRequest) GoString() string
- func (m *ProcessExportRequest) Marshal() (dAtA []byte, err error)
- func (m *ProcessExportRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessExportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessExportRequest) ProtoMessage()
- func (m *ProcessExportRequest) Reset()
- func (m *ProcessExportRequest) Size() (n int)
- func (this *ProcessExportRequest) String() string
- func (m *ProcessExportRequest) Unmarshal(dAtA []byte) error
- func (this *ProcessExportRequest) VerboseEqual(that interface{}) error
- func (m *ProcessExportRequest) XXX_DiscardUnknown()
- func (m *ProcessExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessExportRequest) XXX_Merge(src proto.Message)
- func (m *ProcessExportRequest) XXX_Size() int
- func (m *ProcessExportRequest) XXX_Unmarshal(b []byte) error
- type ProcessHandler
- type ProcessPurgeRequest
- func (*ProcessPurgeRequest) Descriptor() ([]byte, []int)
- func (this *ProcessPurgeRequest) Equal(that interface{}) bool
- func (this *ProcessPurgeRequest) GoString() string
- func (m *ProcessPurgeRequest) Marshal() (dAtA []byte, err error)
- func (m *ProcessPurgeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessPurgeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessPurgeRequest) ProtoMessage()
- func (m *ProcessPurgeRequest) Reset()
- func (m *ProcessPurgeRequest) Size() (n int)
- func (this *ProcessPurgeRequest) String() string
- func (m *ProcessPurgeRequest) Unmarshal(dAtA []byte) error
- func (this *ProcessPurgeRequest) VerboseEqual(that interface{}) error
- func (m *ProcessPurgeRequest) XXX_DiscardUnknown()
- func (m *ProcessPurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessPurgeRequest) XXX_Merge(src proto.Message)
- func (m *ProcessPurgeRequest) XXX_Size() int
- func (m *ProcessPurgeRequest) XXX_Unmarshal(b []byte) error
- type ProcessQueryReply
- func (*ProcessQueryReply) Descriptor() ([]byte, []int)
- func (this *ProcessQueryReply) Equal(that interface{}) bool
- func (m *ProcessQueryReply) GetProcessList() []api.Process
- func (this *ProcessQueryReply) GoString() string
- func (m *ProcessQueryReply) Marshal() (dAtA []byte, err error)
- func (m *ProcessQueryReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessQueryReply) ProtoMessage()
- func (m *ProcessQueryReply) Reset()
- func (m *ProcessQueryReply) Size() (n int)
- func (this *ProcessQueryReply) String() string
- func (m *ProcessQueryReply) Unmarshal(dAtA []byte) error
- func (this *ProcessQueryReply) VerboseEqual(that interface{}) error
- func (m *ProcessQueryReply) XXX_DiscardUnknown()
- func (m *ProcessQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessQueryReply) XXX_Merge(src proto.Message)
- func (m *ProcessQueryReply) XXX_Size() int
- func (m *ProcessQueryReply) XXX_Unmarshal(b []byte) error
- type ProcessQueryRequest
- func (*ProcessQueryRequest) Descriptor() ([]byte, []int)
- func (this *ProcessQueryRequest) Equal(that interface{}) bool
- func (m *ProcessQueryRequest) GetFilter() api.ProcessFilter
- func (this *ProcessQueryRequest) GoString() string
- func (m *ProcessQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *ProcessQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessQueryRequest) ProtoMessage()
- func (m *ProcessQueryRequest) Reset()
- func (m *ProcessQueryRequest) Size() (n int)
- func (this *ProcessQueryRequest) String() string
- func (m *ProcessQueryRequest) Unmarshal(dAtA []byte) error
- func (this *ProcessQueryRequest) VerboseEqual(that interface{}) error
- func (m *ProcessQueryRequest) XXX_DiscardUnknown()
- func (m *ProcessQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessQueryRequest) XXX_Merge(src proto.Message)
- func (m *ProcessQueryRequest) XXX_Size() int
- func (m *ProcessQueryRequest) XXX_Unmarshal(b []byte) error
- type ProcessServer
- type TaskProgress
- func (*TaskProgress) Descriptor() ([]byte, []int)
- func (this *TaskProgress) Equal(that interface{}) bool
- func (m *TaskProgress) GetMaxProgression() uint32
- func (m *TaskProgress) GetMessage() string
- func (m *TaskProgress) GetProgression() uint32
- func (this *TaskProgress) GoString() string
- func (m *TaskProgress) Marshal() (dAtA []byte, err error)
- func (m *TaskProgress) MarshalTo(dAtA []byte) (int, error)
- func (m *TaskProgress) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TaskProgress) ProtoMessage()
- func (m *TaskProgress) Reset()
- func (m *TaskProgress) Size() (n int)
- func (this *TaskProgress) String() string
- func (m *TaskProgress) Unmarshal(dAtA []byte) error
- func (this *TaskProgress) VerboseEqual(that interface{}) error
- func (m *TaskProgress) XXX_DiscardUnknown()
- func (m *TaskProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskProgress) XXX_Merge(src proto.Message)
- func (m *TaskProgress) XXX_Size() int
- func (m *TaskProgress) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthControl = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowControl = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupControl = fmt.Errorf("proto: unexpected end of group") )
var ProcessControlRequest_Command_name = map[int32]string{
0: "NONE",
1: "PAUSE",
2: "RESUME",
3: "CANCEL",
}
var ProcessControlRequest_Command_value = map[string]int32{
"NONE": 0,
"PAUSE": 1,
"RESUME": 2,
"CANCEL": 3,
}
Functions ¶
This section is empty.
Types ¶
type AccountClient ¶
type AccountClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewAccountClient ¶
func NewAccountClient(nc nrpc.NatsConn) *AccountClient
func (*AccountClient) Delete ¶
func (c *AccountClient) Delete(req AccountIDRequest) (err error)
func (*AccountClient) GetAPIKey ¶
func (c *AccountClient) GetAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
func (*AccountClient) List ¶
func (c *AccountClient) List(req AccountListRequest) (resp AccountListReply, err error)
func (*AccountClient) PasswordSet ¶
func (c *AccountClient) PasswordSet(req AccountPasswordSetRequest) (err error)
func (*AccountClient) RenewAPIKey ¶
func (c *AccountClient) RenewAPIKey(req AccountIDRequest) (resp xbus_io_go_xbus_api.Account, err error)
func (*AccountClient) ResetCert ¶
func (c *AccountClient) ResetCert(req AccountIDRequest) (err error)
func (*AccountClient) SetAPIKey ¶
func (c *AccountClient) SetAPIKey(req AccountUpdateRequest) (resp xbus_io_go_xbus_api.Account, err error)
func (*AccountClient) Update ¶
func (c *AccountClient) Update(req AccountUpdateRequest) (resp xbus_io_go_xbus_api.Account, err error)
type AccountHandler ¶
type AccountHandler struct {
// contains filtered or unexported fields
}
AccountHandler provides a NATS subscription handler that can serve a subscription using a given AccountServer implementation.
func NewAccountConcurrentHandler ¶
func NewAccountConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s AccountServer) *AccountHandler
func NewAccountHandler ¶
func NewAccountHandler(ctx context.Context, nc nrpc.NatsConn, s AccountServer) *AccountHandler
func (*AccountHandler) Handler ¶
func (h *AccountHandler) Handler(msg *nats.Msg)
func (*AccountHandler) SetEncodings ¶
func (h *AccountHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*AccountHandler) Subject ¶
func (h *AccountHandler) Subject() string
type AccountIDRequest ¶
type AccountIDRequest struct { AccountID xbus_io_go_xbus_api.UUID `protobuf:"bytes,1,opt,name=accountID,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"accountID"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedAccountIDRequest ¶
func NewPopulatedAccountIDRequest(r randyControl, easy bool) *AccountIDRequest
func (*AccountIDRequest) Descriptor ¶
func (*AccountIDRequest) Descriptor() ([]byte, []int)
func (*AccountIDRequest) Equal ¶
func (this *AccountIDRequest) Equal(that interface{}) bool
func (*AccountIDRequest) GoString ¶
func (this *AccountIDRequest) GoString() string
func (*AccountIDRequest) Marshal ¶
func (m *AccountIDRequest) Marshal() (dAtA []byte, err error)
func (*AccountIDRequest) 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) 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) 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) 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 (*Client) SetEncoding ¶
func (*Client) SetTimeout ¶
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) 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) 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) MarshalToSizedBuffer ¶
func (m *OctetStreamList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OctetStreamList) ProtoMessage ¶
func (*OctetStreamList) ProtoMessage()
func (*OctetStreamList) Reset ¶
func (m *OctetStreamList) Reset()
func (*OctetStreamList) Size ¶
func (m *OctetStreamList) Size() (n int)
func (*OctetStreamList) String ¶
func (this *OctetStreamList) String() string
func (*OctetStreamList) Unmarshal ¶
func (m *OctetStreamList) Unmarshal(dAtA []byte) error
func (*OctetStreamList) VerboseEqual ¶
func (this *OctetStreamList) VerboseEqual(that interface{}) error
func (*OctetStreamList) XXX_DiscardUnknown ¶
func (m *OctetStreamList) XXX_DiscardUnknown()
func (*OctetStreamList) XXX_Marshal ¶
func (m *OctetStreamList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OctetStreamList) XXX_Merge ¶
func (m *OctetStreamList) XXX_Merge(src proto.Message)
func (*OctetStreamList) XXX_Size ¶
func (m *OctetStreamList) XXX_Size() int
func (*OctetStreamList) XXX_Unmarshal ¶
func (m *OctetStreamList) XXX_Unmarshal(b []byte) error
type OctetStreamList_Chunk ¶
type OctetStreamList_Chunk struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Index int64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedOctetStreamList_Chunk ¶
func NewPopulatedOctetStreamList_Chunk(r randyControl, easy bool) *OctetStreamList_Chunk
func (*OctetStreamList_Chunk) Descriptor ¶
func (*OctetStreamList_Chunk) Descriptor() ([]byte, []int)
func (*OctetStreamList_Chunk) Equal ¶
func (this *OctetStreamList_Chunk) Equal(that interface{}) bool
func (*OctetStreamList_Chunk) GetData ¶
func (m *OctetStreamList_Chunk) GetData() []byte
func (*OctetStreamList_Chunk) GetIndex ¶
func (m *OctetStreamList_Chunk) GetIndex() int64
func (*OctetStreamList_Chunk) GoString ¶
func (this *OctetStreamList_Chunk) GoString() string
func (*OctetStreamList_Chunk) Marshal ¶
func (m *OctetStreamList_Chunk) Marshal() (dAtA []byte, err error)
func (*OctetStreamList_Chunk) MarshalTo ¶
func (m *OctetStreamList_Chunk) MarshalTo(dAtA []byte) (int, error)
func (*OctetStreamList_Chunk) MarshalToSizedBuffer ¶
func (m *OctetStreamList_Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OctetStreamList_Chunk) ProtoMessage ¶
func (*OctetStreamList_Chunk) ProtoMessage()
func (*OctetStreamList_Chunk) Reset ¶
func (m *OctetStreamList_Chunk) Reset()
func (*OctetStreamList_Chunk) Size ¶
func (m *OctetStreamList_Chunk) Size() (n int)
func (*OctetStreamList_Chunk) String ¶
func (this *OctetStreamList_Chunk) String() string
func (*OctetStreamList_Chunk) Unmarshal ¶
func (m *OctetStreamList_Chunk) Unmarshal(dAtA []byte) error
func (*OctetStreamList_Chunk) VerboseEqual ¶
func (this *OctetStreamList_Chunk) VerboseEqual(that interface{}) error
func (*OctetStreamList_Chunk) XXX_DiscardUnknown ¶
func (m *OctetStreamList_Chunk) XXX_DiscardUnknown()
func (*OctetStreamList_Chunk) XXX_Marshal ¶
func (m *OctetStreamList_Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OctetStreamList_Chunk) XXX_Merge ¶
func (m *OctetStreamList_Chunk) XXX_Merge(src proto.Message)
func (*OctetStreamList_Chunk) XXX_Size ¶
func (m *OctetStreamList_Chunk) XXX_Size() int
func (*OctetStreamList_Chunk) XXX_Unmarshal ¶
func (m *OctetStreamList_Chunk) XXX_Unmarshal(b []byte) error
type PMProcessClient ¶
type PMProcessClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewPMProcessClient ¶
func NewPMProcessClient(nc nrpc.NatsConn) *PMProcessClient
func (*PMProcessClient) Query ¶
func (c *PMProcessClient) Query( ctx context.Context, req PMProcessQueryRequest, cb func(context.Context, PMProcessQueryReply), ) error
func (*PMProcessClient) SetStatus ¶
func (c *PMProcessClient) SetStatus(req PMProcessSetStatusRequest) (err error)
type PMProcessHandler ¶
type PMProcessHandler struct {
// contains filtered or unexported fields
}
PMProcessHandler provides a NATS subscription handler that can serve a subscription using a given PMProcessServer implementation.
func NewPMProcessConcurrentHandler ¶
func NewPMProcessConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s PMProcessServer) *PMProcessHandler
func NewPMProcessHandler ¶
func NewPMProcessHandler(ctx context.Context, nc nrpc.NatsConn, s PMProcessServer) *PMProcessHandler
func (*PMProcessHandler) Handler ¶
func (h *PMProcessHandler) Handler(msg *nats.Msg)
func (*PMProcessHandler) SetEncodings ¶
func (h *PMProcessHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*PMProcessHandler) Subject ¶
func (h *PMProcessHandler) Subject() string
type PMProcessQueryReply ¶
type PMProcessQueryReply struct { PMProcessList []api.PMProcess `protobuf:"bytes,1,rep,name=pMProcessList,proto3" json:"pMProcessList"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPMProcessQueryReply ¶
func NewPopulatedPMProcessQueryReply(r randyControl, easy bool) *PMProcessQueryReply
func (*PMProcessQueryReply) Descriptor ¶
func (*PMProcessQueryReply) Descriptor() ([]byte, []int)
func (*PMProcessQueryReply) Equal ¶
func (this *PMProcessQueryReply) Equal(that interface{}) bool
func (*PMProcessQueryReply) GetPMProcessList ¶
func (m *PMProcessQueryReply) GetPMProcessList() []api.PMProcess
func (*PMProcessQueryReply) GoString ¶
func (this *PMProcessQueryReply) GoString() string
func (*PMProcessQueryReply) Marshal ¶
func (m *PMProcessQueryReply) Marshal() (dAtA []byte, err error)
func (*PMProcessQueryReply) MarshalTo ¶
func (m *PMProcessQueryReply) MarshalTo(dAtA []byte) (int, error)
func (*PMProcessQueryReply) MarshalToSizedBuffer ¶
func (m *PMProcessQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PMProcessQueryReply) ProtoMessage ¶
func (*PMProcessQueryReply) ProtoMessage()
func (*PMProcessQueryReply) Reset ¶
func (m *PMProcessQueryReply) Reset()
func (*PMProcessQueryReply) Size ¶
func (m *PMProcessQueryReply) Size() (n int)
func (*PMProcessQueryReply) String ¶
func (this *PMProcessQueryReply) String() string
func (*PMProcessQueryReply) Unmarshal ¶
func (m *PMProcessQueryReply) Unmarshal(dAtA []byte) error
func (*PMProcessQueryReply) VerboseEqual ¶
func (this *PMProcessQueryReply) VerboseEqual(that interface{}) error
func (*PMProcessQueryReply) XXX_DiscardUnknown ¶
func (m *PMProcessQueryReply) XXX_DiscardUnknown()
func (*PMProcessQueryReply) XXX_Marshal ¶
func (m *PMProcessQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PMProcessQueryReply) XXX_Merge ¶
func (m *PMProcessQueryReply) XXX_Merge(src proto.Message)
func (*PMProcessQueryReply) XXX_Size ¶
func (m *PMProcessQueryReply) XXX_Size() int
func (*PMProcessQueryReply) XXX_Unmarshal ¶
func (m *PMProcessQueryReply) XXX_Unmarshal(b []byte) error
type PMProcessQueryRequest ¶
type PMProcessQueryRequest struct { Level api.LogLevel `protobuf:"varint,1,opt,name=level,proto3,enum=xbus.LogLevel" json:"level,omitempty"` IncludeClosed bool `protobuf:"varint,2,opt,name=includeClosed,proto3" json:"includeClosed,omitempty"` ProcessIDs []xbus_io_go_xbus_api.UUID `protobuf:"bytes,3,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"processIDs"` ReturnLogs bool `protobuf:"varint,4,opt,name=returnLogs,proto3" json:"returnLogs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPMProcessQueryRequest ¶
func NewPopulatedPMProcessQueryRequest(r randyControl, easy bool) *PMProcessQueryRequest
func (*PMProcessQueryRequest) Descriptor ¶
func (*PMProcessQueryRequest) Descriptor() ([]byte, []int)
func (*PMProcessQueryRequest) Equal ¶
func (this *PMProcessQueryRequest) Equal(that interface{}) bool
func (*PMProcessQueryRequest) GetIncludeClosed ¶
func (m *PMProcessQueryRequest) GetIncludeClosed() bool
func (*PMProcessQueryRequest) GetLevel ¶
func (m *PMProcessQueryRequest) GetLevel() api.LogLevel
func (*PMProcessQueryRequest) GetReturnLogs ¶
func (m *PMProcessQueryRequest) GetReturnLogs() bool
func (*PMProcessQueryRequest) GoString ¶
func (this *PMProcessQueryRequest) GoString() string
func (*PMProcessQueryRequest) Marshal ¶
func (m *PMProcessQueryRequest) Marshal() (dAtA []byte, err error)
func (*PMProcessQueryRequest) MarshalTo ¶
func (m *PMProcessQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*PMProcessQueryRequest) MarshalToSizedBuffer ¶
func (m *PMProcessQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PMProcessQueryRequest) ProtoMessage ¶
func (*PMProcessQueryRequest) ProtoMessage()
func (*PMProcessQueryRequest) Reset ¶
func (m *PMProcessQueryRequest) Reset()
func (*PMProcessQueryRequest) Size ¶
func (m *PMProcessQueryRequest) Size() (n int)
func (*PMProcessQueryRequest) String ¶
func (this *PMProcessQueryRequest) String() string
func (*PMProcessQueryRequest) Unmarshal ¶
func (m *PMProcessQueryRequest) Unmarshal(dAtA []byte) error
func (*PMProcessQueryRequest) VerboseEqual ¶
func (this *PMProcessQueryRequest) VerboseEqual(that interface{}) error
func (*PMProcessQueryRequest) XXX_DiscardUnknown ¶
func (m *PMProcessQueryRequest) XXX_DiscardUnknown()
func (*PMProcessQueryRequest) XXX_Marshal ¶
func (m *PMProcessQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PMProcessQueryRequest) XXX_Merge ¶
func (m *PMProcessQueryRequest) XXX_Merge(src proto.Message)
func (*PMProcessQueryRequest) XXX_Size ¶
func (m *PMProcessQueryRequest) XXX_Size() int
func (*PMProcessQueryRequest) XXX_Unmarshal ¶
func (m *PMProcessQueryRequest) XXX_Unmarshal(b []byte) error
type PMProcessServer ¶
type PMProcessServer interface { Query(ctx context.Context, req PMProcessQueryRequest, pushRep func(PMProcessQueryReply)) (err error) SetStatus(ctx context.Context, req PMProcessSetStatusRequest) (err error) }
PMProcessServer is the interface that providers of the service PMProcess should implement.
type PMProcessSetStatusRequest ¶
type PMProcessSetStatusRequest struct { ProcessID xbus_io_go_xbus_api.UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"processID"` Status api.PMProcess_Status `protobuf:"varint,2,opt,name=status,proto3,enum=xbus.PMProcess_Status" json:"status,omitempty"` Comment string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPMProcessSetStatusRequest ¶
func NewPopulatedPMProcessSetStatusRequest(r randyControl, easy bool) *PMProcessSetStatusRequest
func (*PMProcessSetStatusRequest) Descriptor ¶
func (*PMProcessSetStatusRequest) Descriptor() ([]byte, []int)
func (*PMProcessSetStatusRequest) Equal ¶
func (this *PMProcessSetStatusRequest) Equal(that interface{}) bool
func (*PMProcessSetStatusRequest) GetComment ¶
func (m *PMProcessSetStatusRequest) GetComment() string
func (*PMProcessSetStatusRequest) GetStatus ¶
func (m *PMProcessSetStatusRequest) GetStatus() api.PMProcess_Status
func (*PMProcessSetStatusRequest) GoString ¶
func (this *PMProcessSetStatusRequest) GoString() string
func (*PMProcessSetStatusRequest) Marshal ¶
func (m *PMProcessSetStatusRequest) Marshal() (dAtA []byte, err error)
func (*PMProcessSetStatusRequest) MarshalTo ¶
func (m *PMProcessSetStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*PMProcessSetStatusRequest) MarshalToSizedBuffer ¶
func (m *PMProcessSetStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PMProcessSetStatusRequest) ProtoMessage ¶
func (*PMProcessSetStatusRequest) ProtoMessage()
func (*PMProcessSetStatusRequest) Reset ¶
func (m *PMProcessSetStatusRequest) Reset()
func (*PMProcessSetStatusRequest) Size ¶
func (m *PMProcessSetStatusRequest) Size() (n int)
func (*PMProcessSetStatusRequest) String ¶
func (this *PMProcessSetStatusRequest) String() string
func (*PMProcessSetStatusRequest) Unmarshal ¶
func (m *PMProcessSetStatusRequest) Unmarshal(dAtA []byte) error
func (*PMProcessSetStatusRequest) VerboseEqual ¶
func (this *PMProcessSetStatusRequest) VerboseEqual(that interface{}) error
func (*PMProcessSetStatusRequest) XXX_DiscardUnknown ¶
func (m *PMProcessSetStatusRequest) XXX_DiscardUnknown()
func (*PMProcessSetStatusRequest) XXX_Marshal ¶
func (m *PMProcessSetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PMProcessSetStatusRequest) XXX_Merge ¶
func (m *PMProcessSetStatusRequest) XXX_Merge(src proto.Message)
func (*PMProcessSetStatusRequest) XXX_Size ¶
func (m *PMProcessSetStatusRequest) XXX_Size() int
func (*PMProcessSetStatusRequest) XXX_Unmarshal ¶
func (m *PMProcessSetStatusRequest) XXX_Unmarshal(b []byte) error
type PipelineClient ¶
type PipelineClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewPipelineClient ¶
func NewPipelineClient(nc nrpc.NatsConn) *PipelineClient
func (*PipelineClient) GetGraph ¶
func (c *PipelineClient) GetGraph(req xbus_io_go_xbus_api.PipelineInfo) (resp xbus_io_go_xbus_api.StringReply, err error)
func (*PipelineClient) Query ¶
func (c *PipelineClient) Query(req PipelineQueryRequest) (resp PipelineQueryReply, err error)
func (*PipelineClient) Save ¶
func (c *PipelineClient) Save(req PipelineSaveRequest) (resp PipelineSaveReply, err error)
func (*PipelineClient) SetStatus ¶
func (c *PipelineClient) SetStatus(req xbus_io_go_xbus_api.PipelineInfo) (resp PipelineSetStatusReply, err error)
type PipelineHandler ¶
type PipelineHandler struct {
// contains filtered or unexported fields
}
PipelineHandler provides a NATS subscription handler that can serve a subscription using a given PipelineServer implementation.
func NewPipelineConcurrentHandler ¶
func NewPipelineConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s PipelineServer) *PipelineHandler
func NewPipelineHandler ¶
func NewPipelineHandler(ctx context.Context, nc nrpc.NatsConn, s PipelineServer) *PipelineHandler
func (*PipelineHandler) Handler ¶
func (h *PipelineHandler) Handler(msg *nats.Msg)
func (*PipelineHandler) SetEncodings ¶
func (h *PipelineHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*PipelineHandler) Subject ¶
func (h *PipelineHandler) Subject() string
type PipelineQueryReply ¶
type PipelineQueryReply struct { PipelineList []api.PipelineInfo `protobuf:"bytes,1,rep,name=pipelineList,proto3" json:"pipelineList"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineQueryReply ¶
func NewPopulatedPipelineQueryReply(r randyControl, easy bool) *PipelineQueryReply
func (*PipelineQueryReply) Descriptor ¶
func (*PipelineQueryReply) Descriptor() ([]byte, []int)
func (*PipelineQueryReply) Equal ¶
func (this *PipelineQueryReply) Equal(that interface{}) bool
func (*PipelineQueryReply) GetPipelineList ¶
func (m *PipelineQueryReply) GetPipelineList() []api.PipelineInfo
func (*PipelineQueryReply) GoString ¶
func (this *PipelineQueryReply) GoString() string
func (*PipelineQueryReply) Marshal ¶
func (m *PipelineQueryReply) Marshal() (dAtA []byte, err error)
func (*PipelineQueryReply) MarshalTo ¶
func (m *PipelineQueryReply) MarshalTo(dAtA []byte) (int, error)
func (*PipelineQueryReply) MarshalToSizedBuffer ¶
func (m *PipelineQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineQueryReply) ProtoMessage ¶
func (*PipelineQueryReply) ProtoMessage()
func (*PipelineQueryReply) Reset ¶
func (m *PipelineQueryReply) Reset()
func (*PipelineQueryReply) Size ¶
func (m *PipelineQueryReply) Size() (n int)
func (*PipelineQueryReply) String ¶
func (this *PipelineQueryReply) String() string
func (*PipelineQueryReply) Unmarshal ¶
func (m *PipelineQueryReply) Unmarshal(dAtA []byte) error
func (*PipelineQueryReply) VerboseEqual ¶
func (this *PipelineQueryReply) VerboseEqual(that interface{}) error
func (*PipelineQueryReply) XXX_DiscardUnknown ¶
func (m *PipelineQueryReply) XXX_DiscardUnknown()
func (*PipelineQueryReply) XXX_Marshal ¶
func (m *PipelineQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineQueryReply) XXX_Merge ¶
func (m *PipelineQueryReply) XXX_Merge(src proto.Message)
func (*PipelineQueryReply) XXX_Size ¶
func (m *PipelineQueryReply) XXX_Size() int
func (*PipelineQueryReply) XXX_Unmarshal ¶
func (m *PipelineQueryReply) XXX_Unmarshal(b []byte) error
type PipelineQueryRequest ¶
type PipelineQueryRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineQueryRequest ¶
func NewPopulatedPipelineQueryRequest(r randyControl, easy bool) *PipelineQueryRequest
func (*PipelineQueryRequest) Descriptor ¶
func (*PipelineQueryRequest) Descriptor() ([]byte, []int)
func (*PipelineQueryRequest) Equal ¶
func (this *PipelineQueryRequest) Equal(that interface{}) bool
func (*PipelineQueryRequest) GetName ¶
func (m *PipelineQueryRequest) GetName() string
func (*PipelineQueryRequest) GoString ¶
func (this *PipelineQueryRequest) GoString() string
func (*PipelineQueryRequest) Marshal ¶
func (m *PipelineQueryRequest) Marshal() (dAtA []byte, err error)
func (*PipelineQueryRequest) MarshalTo ¶
func (m *PipelineQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*PipelineQueryRequest) MarshalToSizedBuffer ¶
func (m *PipelineQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineQueryRequest) ProtoMessage ¶
func (*PipelineQueryRequest) ProtoMessage()
func (*PipelineQueryRequest) Reset ¶
func (m *PipelineQueryRequest) Reset()
func (*PipelineQueryRequest) Size ¶
func (m *PipelineQueryRequest) Size() (n int)
func (*PipelineQueryRequest) String ¶
func (this *PipelineQueryRequest) String() string
func (*PipelineQueryRequest) Unmarshal ¶
func (m *PipelineQueryRequest) Unmarshal(dAtA []byte) error
func (*PipelineQueryRequest) VerboseEqual ¶
func (this *PipelineQueryRequest) VerboseEqual(that interface{}) error
func (*PipelineQueryRequest) XXX_DiscardUnknown ¶
func (m *PipelineQueryRequest) XXX_DiscardUnknown()
func (*PipelineQueryRequest) XXX_Marshal ¶
func (m *PipelineQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineQueryRequest) XXX_Merge ¶
func (m *PipelineQueryRequest) XXX_Merge(src proto.Message)
func (*PipelineQueryRequest) XXX_Size ¶
func (m *PipelineQueryRequest) XXX_Size() int
func (*PipelineQueryRequest) XXX_Unmarshal ¶
func (m *PipelineQueryRequest) XXX_Unmarshal(b []byte) error
type PipelineSaveReply ¶
type PipelineSaveReply struct { Info api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` Graph string `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"` IsValid bool `protobuf:"varint,3,opt,name=isValid,proto3" json:"isValid,omitempty"` ValidationMessages []string `protobuf:"bytes,4,rep,name=validationMessages,proto3" json:"validationMessages,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineSaveReply ¶
func NewPopulatedPipelineSaveReply(r randyControl, easy bool) *PipelineSaveReply
func (*PipelineSaveReply) Descriptor ¶
func (*PipelineSaveReply) Descriptor() ([]byte, []int)
func (*PipelineSaveReply) Equal ¶
func (this *PipelineSaveReply) Equal(that interface{}) bool
func (*PipelineSaveReply) GetGraph ¶
func (m *PipelineSaveReply) GetGraph() string
func (*PipelineSaveReply) GetInfo ¶
func (m *PipelineSaveReply) GetInfo() api.PipelineInfo
func (*PipelineSaveReply) GetIsValid ¶
func (m *PipelineSaveReply) GetIsValid() bool
func (*PipelineSaveReply) GetValidationMessages ¶
func (m *PipelineSaveReply) GetValidationMessages() []string
func (*PipelineSaveReply) GoString ¶
func (this *PipelineSaveReply) GoString() string
func (*PipelineSaveReply) Marshal ¶
func (m *PipelineSaveReply) Marshal() (dAtA []byte, err error)
func (*PipelineSaveReply) MarshalTo ¶
func (m *PipelineSaveReply) MarshalTo(dAtA []byte) (int, error)
func (*PipelineSaveReply) MarshalToSizedBuffer ¶
func (m *PipelineSaveReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineSaveReply) ProtoMessage ¶
func (*PipelineSaveReply) ProtoMessage()
func (*PipelineSaveReply) Reset ¶
func (m *PipelineSaveReply) Reset()
func (*PipelineSaveReply) Size ¶
func (m *PipelineSaveReply) Size() (n int)
func (*PipelineSaveReply) String ¶
func (this *PipelineSaveReply) String() string
func (*PipelineSaveReply) Unmarshal ¶
func (m *PipelineSaveReply) Unmarshal(dAtA []byte) error
func (*PipelineSaveReply) VerboseEqual ¶
func (this *PipelineSaveReply) VerboseEqual(that interface{}) error
func (*PipelineSaveReply) XXX_DiscardUnknown ¶
func (m *PipelineSaveReply) XXX_DiscardUnknown()
func (*PipelineSaveReply) XXX_Marshal ¶
func (m *PipelineSaveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineSaveReply) XXX_Merge ¶
func (m *PipelineSaveReply) XXX_Merge(src proto.Message)
func (*PipelineSaveReply) XXX_Size ¶
func (m *PipelineSaveReply) XXX_Size() int
func (*PipelineSaveReply) XXX_Unmarshal ¶
func (m *PipelineSaveReply) XXX_Unmarshal(b []byte) error
type PipelineSaveRequest ¶
type PipelineSaveRequest struct { Info api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` Graph string `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineSaveRequest ¶
func NewPopulatedPipelineSaveRequest(r randyControl, easy bool) *PipelineSaveRequest
func (*PipelineSaveRequest) Descriptor ¶
func (*PipelineSaveRequest) Descriptor() ([]byte, []int)
func (*PipelineSaveRequest) Equal ¶
func (this *PipelineSaveRequest) Equal(that interface{}) bool
func (*PipelineSaveRequest) GetGraph ¶
func (m *PipelineSaveRequest) GetGraph() string
func (*PipelineSaveRequest) GetInfo ¶
func (m *PipelineSaveRequest) GetInfo() api.PipelineInfo
func (*PipelineSaveRequest) GoString ¶
func (this *PipelineSaveRequest) GoString() string
func (*PipelineSaveRequest) Marshal ¶
func (m *PipelineSaveRequest) Marshal() (dAtA []byte, err error)
func (*PipelineSaveRequest) MarshalTo ¶
func (m *PipelineSaveRequest) MarshalTo(dAtA []byte) (int, error)
func (*PipelineSaveRequest) MarshalToSizedBuffer ¶
func (m *PipelineSaveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineSaveRequest) ProtoMessage ¶
func (*PipelineSaveRequest) ProtoMessage()
func (*PipelineSaveRequest) Reset ¶
func (m *PipelineSaveRequest) Reset()
func (*PipelineSaveRequest) Size ¶
func (m *PipelineSaveRequest) Size() (n int)
func (*PipelineSaveRequest) String ¶
func (this *PipelineSaveRequest) String() string
func (*PipelineSaveRequest) Unmarshal ¶
func (m *PipelineSaveRequest) Unmarshal(dAtA []byte) error
func (*PipelineSaveRequest) VerboseEqual ¶
func (this *PipelineSaveRequest) VerboseEqual(that interface{}) error
func (*PipelineSaveRequest) XXX_DiscardUnknown ¶
func (m *PipelineSaveRequest) XXX_DiscardUnknown()
func (*PipelineSaveRequest) XXX_Marshal ¶
func (m *PipelineSaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineSaveRequest) XXX_Merge ¶
func (m *PipelineSaveRequest) XXX_Merge(src proto.Message)
func (*PipelineSaveRequest) XXX_Size ¶
func (m *PipelineSaveRequest) XXX_Size() int
func (*PipelineSaveRequest) XXX_Unmarshal ¶
func (m *PipelineSaveRequest) XXX_Unmarshal(b []byte) error
type PipelineServer ¶
type PipelineServer interface { Query(ctx context.Context, req PipelineQueryRequest) (resp PipelineQueryReply, err error) Save(ctx context.Context, req PipelineSaveRequest) (resp PipelineSaveReply, err error) SetStatus(ctx context.Context, req xbus_io_go_xbus_api.PipelineInfo) (resp PipelineSetStatusReply, err error) GetGraph(ctx context.Context, req xbus_io_go_xbus_api.PipelineInfo) (resp xbus_io_go_xbus_api.StringReply, err error) }
PipelineServer is the interface that providers of the service Pipeline should implement.
type PipelineSetStatusReply ¶
type PipelineSetStatusReply struct { Info api.PipelineInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info"` IsValid bool `protobuf:"varint,2,opt,name=isValid,proto3" json:"isValid,omitempty"` ValidationMessages []string `protobuf:"bytes,4,rep,name=validationMessages,proto3" json:"validationMessages,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedPipelineSetStatusReply ¶
func NewPopulatedPipelineSetStatusReply(r randyControl, easy bool) *PipelineSetStatusReply
func (*PipelineSetStatusReply) Descriptor ¶
func (*PipelineSetStatusReply) Descriptor() ([]byte, []int)
func (*PipelineSetStatusReply) Equal ¶
func (this *PipelineSetStatusReply) Equal(that interface{}) bool
func (*PipelineSetStatusReply) GetInfo ¶
func (m *PipelineSetStatusReply) GetInfo() api.PipelineInfo
func (*PipelineSetStatusReply) GetIsValid ¶
func (m *PipelineSetStatusReply) GetIsValid() bool
func (*PipelineSetStatusReply) GetValidationMessages ¶
func (m *PipelineSetStatusReply) GetValidationMessages() []string
func (*PipelineSetStatusReply) GoString ¶
func (this *PipelineSetStatusReply) GoString() string
func (*PipelineSetStatusReply) Marshal ¶
func (m *PipelineSetStatusReply) Marshal() (dAtA []byte, err error)
func (*PipelineSetStatusReply) MarshalTo ¶
func (m *PipelineSetStatusReply) MarshalTo(dAtA []byte) (int, error)
func (*PipelineSetStatusReply) MarshalToSizedBuffer ¶
func (m *PipelineSetStatusReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineSetStatusReply) ProtoMessage ¶
func (*PipelineSetStatusReply) ProtoMessage()
func (*PipelineSetStatusReply) Reset ¶
func (m *PipelineSetStatusReply) Reset()
func (*PipelineSetStatusReply) Size ¶
func (m *PipelineSetStatusReply) Size() (n int)
func (*PipelineSetStatusReply) String ¶
func (this *PipelineSetStatusReply) String() string
func (*PipelineSetStatusReply) Unmarshal ¶
func (m *PipelineSetStatusReply) Unmarshal(dAtA []byte) error
func (*PipelineSetStatusReply) VerboseEqual ¶
func (this *PipelineSetStatusReply) VerboseEqual(that interface{}) error
func (*PipelineSetStatusReply) XXX_DiscardUnknown ¶
func (m *PipelineSetStatusReply) XXX_DiscardUnknown()
func (*PipelineSetStatusReply) XXX_Marshal ¶
func (m *PipelineSetStatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineSetStatusReply) XXX_Merge ¶
func (m *PipelineSetStatusReply) XXX_Merge(src proto.Message)
func (*PipelineSetStatusReply) XXX_Size ¶
func (m *PipelineSetStatusReply) XXX_Size() int
func (*PipelineSetStatusReply) XXX_Unmarshal ¶
func (m *PipelineSetStatusReply) XXX_Unmarshal(b []byte) error
type ProcessClient ¶
type ProcessClient struct { PkgSubject string Subject string Encoding string Timeout time.Duration // contains filtered or unexported fields }
func NewProcessClient ¶
func NewProcessClient(nc nrpc.NatsConn) *ProcessClient
func (*ProcessClient) Control ¶
func (c *ProcessClient) Control(req ProcessControlRequest) (err error)
func (*ProcessClient) Export ¶
func (c *ProcessClient) Export(req ProcessExportRequest) (resp ProcessExportReply, err error)
func (*ProcessClient) ExportStream ¶
func (c *ProcessClient) ExportStream( ctx context.Context, req ProcessExportRequest, cb func(context.Context, OctetStreamList), ) error
func (*ProcessClient) Purge ¶
func (c *ProcessClient) Purge( ctx context.Context, req ProcessPurgeRequest, cb func(context.Context, TaskProgress), ) error
func (*ProcessClient) Query ¶
func (c *ProcessClient) Query( ctx context.Context, req ProcessQueryRequest, cb func(context.Context, ProcessQueryReply), ) error
type ProcessControlRequest ¶
type ProcessControlRequest struct { ProcessID xbus_io_go_xbus_api.UUID `protobuf:"bytes,1,opt,name=processID,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"processID"` Command ProcessControlRequest_Command `protobuf:"varint,2,opt,name=command,proto3,enum=xbus.control.ProcessControlRequest_Command" json:"command,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessControlRequest ¶
func NewPopulatedProcessControlRequest(r randyControl, easy bool) *ProcessControlRequest
func (*ProcessControlRequest) Descriptor ¶
func (*ProcessControlRequest) Descriptor() ([]byte, []int)
func (*ProcessControlRequest) Equal ¶
func (this *ProcessControlRequest) Equal(that interface{}) bool
func (*ProcessControlRequest) GetCommand ¶
func (m *ProcessControlRequest) GetCommand() ProcessControlRequest_Command
func (*ProcessControlRequest) GoString ¶
func (this *ProcessControlRequest) GoString() string
func (*ProcessControlRequest) Marshal ¶
func (m *ProcessControlRequest) Marshal() (dAtA []byte, err error)
func (*ProcessControlRequest) MarshalTo ¶
func (m *ProcessControlRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProcessControlRequest) MarshalToSizedBuffer ¶
func (m *ProcessControlRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessControlRequest) ProtoMessage ¶
func (*ProcessControlRequest) ProtoMessage()
func (*ProcessControlRequest) Reset ¶
func (m *ProcessControlRequest) Reset()
func (*ProcessControlRequest) Size ¶
func (m *ProcessControlRequest) Size() (n int)
func (*ProcessControlRequest) String ¶
func (this *ProcessControlRequest) String() string
func (*ProcessControlRequest) Unmarshal ¶
func (m *ProcessControlRequest) Unmarshal(dAtA []byte) error
func (*ProcessControlRequest) VerboseEqual ¶
func (this *ProcessControlRequest) VerboseEqual(that interface{}) error
func (*ProcessControlRequest) XXX_DiscardUnknown ¶
func (m *ProcessControlRequest) XXX_DiscardUnknown()
func (*ProcessControlRequest) XXX_Marshal ¶
func (m *ProcessControlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessControlRequest) XXX_Merge ¶
func (m *ProcessControlRequest) XXX_Merge(src proto.Message)
func (*ProcessControlRequest) XXX_Size ¶
func (m *ProcessControlRequest) XXX_Size() int
func (*ProcessControlRequest) XXX_Unmarshal ¶
func (m *ProcessControlRequest) XXX_Unmarshal(b []byte) error
type ProcessControlRequest_Command ¶
type ProcessControlRequest_Command int32
const ( ProcessControlRequest_NONE ProcessControlRequest_Command = 0 ProcessControlRequest_PAUSE ProcessControlRequest_Command = 1 ProcessControlRequest_RESUME ProcessControlRequest_Command = 2 ProcessControlRequest_CANCEL ProcessControlRequest_Command = 3 )
func (ProcessControlRequest_Command) EnumDescriptor ¶
func (ProcessControlRequest_Command) EnumDescriptor() ([]byte, []int)
func (ProcessControlRequest_Command) String ¶
func (x ProcessControlRequest_Command) String() string
type ProcessExportReply ¶
type ProcessExportReply struct { ProcessList []string `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessExportReply ¶
func NewPopulatedProcessExportReply(r randyControl, easy bool) *ProcessExportReply
func (*ProcessExportReply) Descriptor ¶
func (*ProcessExportReply) Descriptor() ([]byte, []int)
func (*ProcessExportReply) Equal ¶
func (this *ProcessExportReply) Equal(that interface{}) bool
func (*ProcessExportReply) GetProcessList ¶
func (m *ProcessExportReply) GetProcessList() []string
func (*ProcessExportReply) GoString ¶
func (this *ProcessExportReply) GoString() string
func (*ProcessExportReply) Marshal ¶
func (m *ProcessExportReply) Marshal() (dAtA []byte, err error)
func (*ProcessExportReply) MarshalTo ¶
func (m *ProcessExportReply) MarshalTo(dAtA []byte) (int, error)
func (*ProcessExportReply) MarshalToSizedBuffer ¶
func (m *ProcessExportReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessExportReply) ProtoMessage ¶
func (*ProcessExportReply) ProtoMessage()
func (*ProcessExportReply) Reset ¶
func (m *ProcessExportReply) Reset()
func (*ProcessExportReply) Size ¶
func (m *ProcessExportReply) Size() (n int)
func (*ProcessExportReply) String ¶
func (this *ProcessExportReply) String() string
func (*ProcessExportReply) Unmarshal ¶
func (m *ProcessExportReply) Unmarshal(dAtA []byte) error
func (*ProcessExportReply) VerboseEqual ¶
func (this *ProcessExportReply) VerboseEqual(that interface{}) error
func (*ProcessExportReply) XXX_DiscardUnknown ¶
func (m *ProcessExportReply) XXX_DiscardUnknown()
func (*ProcessExportReply) XXX_Marshal ¶
func (m *ProcessExportReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessExportReply) XXX_Merge ¶
func (m *ProcessExportReply) XXX_Merge(src proto.Message)
func (*ProcessExportReply) XXX_Size ¶
func (m *ProcessExportReply) XXX_Size() int
func (*ProcessExportReply) XXX_Unmarshal ¶
func (m *ProcessExportReply) XXX_Unmarshal(b []byte) error
type ProcessExportRequest ¶
type ProcessExportRequest struct { ProcessIDs []xbus_io_go_xbus_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"processIDs"` ExportEnvelope bool `protobuf:"varint,2,opt,name=exportEnvelope,proto3" json:"exportEnvelope,omitempty"` ExportJobs bool `protobuf:"varint,8,opt,name=exportJobs,proto3" json:"exportJobs,omitempty"` ExportLogs bool `protobuf:"varint,4,opt,name=exportLogs,proto3" json:"exportLogs,omitempty"` ExportProcessLogs bool `protobuf:"varint,5,opt,name=exportProcessLogs,proto3" json:"exportProcessLogs,omitempty"` EnvelopeSizeLimit int64 `protobuf:"varint,3,opt,name=envelopeSizeLimit,proto3" json:"envelopeSizeLimit,omitempty"` LogLevel api.LogLevel `protobuf:"varint,6,opt,name=logLevel,proto3,enum=xbus.LogLevel" json:"logLevel,omitempty"` ExportFull bool `protobuf:"varint,7,opt,name=exportFull,proto3" json:"exportFull,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessExportRequest ¶
func NewPopulatedProcessExportRequest(r randyControl, easy bool) *ProcessExportRequest
func (*ProcessExportRequest) Descriptor ¶
func (*ProcessExportRequest) Descriptor() ([]byte, []int)
func (*ProcessExportRequest) Equal ¶
func (this *ProcessExportRequest) Equal(that interface{}) bool
func (*ProcessExportRequest) GetEnvelopeSizeLimit ¶
func (m *ProcessExportRequest) GetEnvelopeSizeLimit() int64
func (*ProcessExportRequest) GetExportEnvelope ¶
func (m *ProcessExportRequest) GetExportEnvelope() bool
func (*ProcessExportRequest) GetExportFull ¶
func (m *ProcessExportRequest) GetExportFull() bool
func (*ProcessExportRequest) GetExportJobs ¶
func (m *ProcessExportRequest) GetExportJobs() bool
func (*ProcessExportRequest) GetExportLogs ¶
func (m *ProcessExportRequest) GetExportLogs() bool
func (*ProcessExportRequest) GetExportProcessLogs ¶
func (m *ProcessExportRequest) GetExportProcessLogs() bool
func (*ProcessExportRequest) GetLogLevel ¶
func (m *ProcessExportRequest) GetLogLevel() api.LogLevel
func (*ProcessExportRequest) GoString ¶
func (this *ProcessExportRequest) GoString() string
func (*ProcessExportRequest) Marshal ¶
func (m *ProcessExportRequest) Marshal() (dAtA []byte, err error)
func (*ProcessExportRequest) MarshalTo ¶
func (m *ProcessExportRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProcessExportRequest) MarshalToSizedBuffer ¶
func (m *ProcessExportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessExportRequest) ProtoMessage ¶
func (*ProcessExportRequest) ProtoMessage()
func (*ProcessExportRequest) Reset ¶
func (m *ProcessExportRequest) Reset()
func (*ProcessExportRequest) Size ¶
func (m *ProcessExportRequest) Size() (n int)
func (*ProcessExportRequest) String ¶
func (this *ProcessExportRequest) String() string
func (*ProcessExportRequest) Unmarshal ¶
func (m *ProcessExportRequest) Unmarshal(dAtA []byte) error
func (*ProcessExportRequest) VerboseEqual ¶
func (this *ProcessExportRequest) VerboseEqual(that interface{}) error
func (*ProcessExportRequest) XXX_DiscardUnknown ¶
func (m *ProcessExportRequest) XXX_DiscardUnknown()
func (*ProcessExportRequest) XXX_Marshal ¶
func (m *ProcessExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessExportRequest) XXX_Merge ¶
func (m *ProcessExportRequest) XXX_Merge(src proto.Message)
func (*ProcessExportRequest) XXX_Size ¶
func (m *ProcessExportRequest) XXX_Size() int
func (*ProcessExportRequest) XXX_Unmarshal ¶
func (m *ProcessExportRequest) XXX_Unmarshal(b []byte) error
type ProcessHandler ¶
type ProcessHandler struct {
// contains filtered or unexported fields
}
ProcessHandler provides a NATS subscription handler that can serve a subscription using a given ProcessServer implementation.
func NewProcessConcurrentHandler ¶
func NewProcessConcurrentHandler(workers *nrpc.WorkerPool, nc nrpc.NatsConn, s ProcessServer) *ProcessHandler
func NewProcessHandler ¶
func NewProcessHandler(ctx context.Context, nc nrpc.NatsConn, s ProcessServer) *ProcessHandler
func (*ProcessHandler) Handler ¶
func (h *ProcessHandler) Handler(msg *nats.Msg)
func (*ProcessHandler) SetEncodings ¶
func (h *ProcessHandler) SetEncodings(encodings []string)
SetEncodings sets the output encodings when using a '*Publish' function
func (*ProcessHandler) Subject ¶
func (h *ProcessHandler) Subject() string
type ProcessPurgeRequest ¶
type ProcessPurgeRequest struct { ProcessIDs []xbus_io_go_xbus_api.UUID `protobuf:"bytes,1,rep,name=processIDs,proto3,customtype=xbus.io/go-xbus/api.UUID" json:"processIDs"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessPurgeRequest ¶
func NewPopulatedProcessPurgeRequest(r randyControl, easy bool) *ProcessPurgeRequest
func (*ProcessPurgeRequest) Descriptor ¶
func (*ProcessPurgeRequest) Descriptor() ([]byte, []int)
func (*ProcessPurgeRequest) Equal ¶
func (this *ProcessPurgeRequest) Equal(that interface{}) bool
func (*ProcessPurgeRequest) GoString ¶
func (this *ProcessPurgeRequest) GoString() string
func (*ProcessPurgeRequest) Marshal ¶
func (m *ProcessPurgeRequest) Marshal() (dAtA []byte, err error)
func (*ProcessPurgeRequest) MarshalTo ¶
func (m *ProcessPurgeRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProcessPurgeRequest) MarshalToSizedBuffer ¶
func (m *ProcessPurgeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessPurgeRequest) ProtoMessage ¶
func (*ProcessPurgeRequest) ProtoMessage()
func (*ProcessPurgeRequest) Reset ¶
func (m *ProcessPurgeRequest) Reset()
func (*ProcessPurgeRequest) Size ¶
func (m *ProcessPurgeRequest) Size() (n int)
func (*ProcessPurgeRequest) String ¶
func (this *ProcessPurgeRequest) String() string
func (*ProcessPurgeRequest) Unmarshal ¶
func (m *ProcessPurgeRequest) Unmarshal(dAtA []byte) error
func (*ProcessPurgeRequest) VerboseEqual ¶
func (this *ProcessPurgeRequest) VerboseEqual(that interface{}) error
func (*ProcessPurgeRequest) XXX_DiscardUnknown ¶
func (m *ProcessPurgeRequest) XXX_DiscardUnknown()
func (*ProcessPurgeRequest) XXX_Marshal ¶
func (m *ProcessPurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessPurgeRequest) XXX_Merge ¶
func (m *ProcessPurgeRequest) XXX_Merge(src proto.Message)
func (*ProcessPurgeRequest) XXX_Size ¶
func (m *ProcessPurgeRequest) XXX_Size() int
func (*ProcessPurgeRequest) XXX_Unmarshal ¶
func (m *ProcessPurgeRequest) XXX_Unmarshal(b []byte) error
type ProcessQueryReply ¶
type ProcessQueryReply struct { ProcessList []api.Process `protobuf:"bytes,1,rep,name=processList,proto3" json:"processList"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessQueryReply ¶
func NewPopulatedProcessQueryReply(r randyControl, easy bool) *ProcessQueryReply
func (*ProcessQueryReply) Descriptor ¶
func (*ProcessQueryReply) Descriptor() ([]byte, []int)
func (*ProcessQueryReply) Equal ¶
func (this *ProcessQueryReply) Equal(that interface{}) bool
func (*ProcessQueryReply) GetProcessList ¶
func (m *ProcessQueryReply) GetProcessList() []api.Process
func (*ProcessQueryReply) GoString ¶
func (this *ProcessQueryReply) GoString() string
func (*ProcessQueryReply) Marshal ¶
func (m *ProcessQueryReply) Marshal() (dAtA []byte, err error)
func (*ProcessQueryReply) MarshalTo ¶
func (m *ProcessQueryReply) MarshalTo(dAtA []byte) (int, error)
func (*ProcessQueryReply) MarshalToSizedBuffer ¶
func (m *ProcessQueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessQueryReply) ProtoMessage ¶
func (*ProcessQueryReply) ProtoMessage()
func (*ProcessQueryReply) Reset ¶
func (m *ProcessQueryReply) Reset()
func (*ProcessQueryReply) Size ¶
func (m *ProcessQueryReply) Size() (n int)
func (*ProcessQueryReply) String ¶
func (this *ProcessQueryReply) String() string
func (*ProcessQueryReply) Unmarshal ¶
func (m *ProcessQueryReply) Unmarshal(dAtA []byte) error
func (*ProcessQueryReply) VerboseEqual ¶
func (this *ProcessQueryReply) VerboseEqual(that interface{}) error
func (*ProcessQueryReply) XXX_DiscardUnknown ¶
func (m *ProcessQueryReply) XXX_DiscardUnknown()
func (*ProcessQueryReply) XXX_Marshal ¶
func (m *ProcessQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessQueryReply) XXX_Merge ¶
func (m *ProcessQueryReply) XXX_Merge(src proto.Message)
func (*ProcessQueryReply) XXX_Size ¶
func (m *ProcessQueryReply) XXX_Size() int
func (*ProcessQueryReply) XXX_Unmarshal ¶
func (m *ProcessQueryReply) XXX_Unmarshal(b []byte) error
type ProcessQueryRequest ¶
type ProcessQueryRequest struct { Filter api.ProcessFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedProcessQueryRequest ¶
func NewPopulatedProcessQueryRequest(r randyControl, easy bool) *ProcessQueryRequest
func (*ProcessQueryRequest) Descriptor ¶
func (*ProcessQueryRequest) Descriptor() ([]byte, []int)
func (*ProcessQueryRequest) Equal ¶
func (this *ProcessQueryRequest) Equal(that interface{}) bool
func (*ProcessQueryRequest) GetFilter ¶
func (m *ProcessQueryRequest) GetFilter() api.ProcessFilter
func (*ProcessQueryRequest) GoString ¶
func (this *ProcessQueryRequest) GoString() string
func (*ProcessQueryRequest) Marshal ¶
func (m *ProcessQueryRequest) Marshal() (dAtA []byte, err error)
func (*ProcessQueryRequest) MarshalTo ¶
func (m *ProcessQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProcessQueryRequest) MarshalToSizedBuffer ¶
func (m *ProcessQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessQueryRequest) ProtoMessage ¶
func (*ProcessQueryRequest) ProtoMessage()
func (*ProcessQueryRequest) Reset ¶
func (m *ProcessQueryRequest) Reset()
func (*ProcessQueryRequest) Size ¶
func (m *ProcessQueryRequest) Size() (n int)
func (*ProcessQueryRequest) String ¶
func (this *ProcessQueryRequest) String() string
func (*ProcessQueryRequest) Unmarshal ¶
func (m *ProcessQueryRequest) Unmarshal(dAtA []byte) error
func (*ProcessQueryRequest) VerboseEqual ¶
func (this *ProcessQueryRequest) VerboseEqual(that interface{}) error
func (*ProcessQueryRequest) XXX_DiscardUnknown ¶
func (m *ProcessQueryRequest) XXX_DiscardUnknown()
func (*ProcessQueryRequest) XXX_Marshal ¶
func (m *ProcessQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessQueryRequest) XXX_Merge ¶
func (m *ProcessQueryRequest) XXX_Merge(src proto.Message)
func (*ProcessQueryRequest) XXX_Size ¶
func (m *ProcessQueryRequest) XXX_Size() int
func (*ProcessQueryRequest) XXX_Unmarshal ¶
func (m *ProcessQueryRequest) XXX_Unmarshal(b []byte) error
type ProcessServer ¶
type ProcessServer interface { Query(ctx context.Context, req ProcessQueryRequest, pushRep func(ProcessQueryReply)) (err error) Control(ctx context.Context, req ProcessControlRequest) (err error) Export(ctx context.Context, req ProcessExportRequest) (resp ProcessExportReply, err error) ExportStream(ctx context.Context, req ProcessExportRequest, pushRep func(OctetStreamList)) (err error) Purge(ctx context.Context, req ProcessPurgeRequest, pushRep func(TaskProgress)) (err error) }
ProcessServer is the interface that providers of the service Process should implement.
type TaskProgress ¶
type TaskProgress struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Progression uint32 `protobuf:"varint,2,opt,name=progression,proto3" json:"progression,omitempty"` MaxProgression uint32 `protobuf:"varint,3,opt,name=maxProgression,proto3" json:"maxProgression,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewPopulatedTaskProgress ¶
func NewPopulatedTaskProgress(r randyControl, easy bool) *TaskProgress
func (*TaskProgress) Descriptor ¶
func (*TaskProgress) Descriptor() ([]byte, []int)
func (*TaskProgress) Equal ¶
func (this *TaskProgress) Equal(that interface{}) bool
func (*TaskProgress) GetMaxProgression ¶
func (m *TaskProgress) GetMaxProgression() uint32
func (*TaskProgress) GetMessage ¶
func (m *TaskProgress) GetMessage() string
func (*TaskProgress) GetProgression ¶
func (m *TaskProgress) GetProgression() uint32
func (*TaskProgress) GoString ¶
func (this *TaskProgress) GoString() string
func (*TaskProgress) Marshal ¶
func (m *TaskProgress) Marshal() (dAtA []byte, err error)
func (*TaskProgress) 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