pb

package
v0.0.0-...-ec57856 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMain        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMain          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMain = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CreateOrchestratorActivityCommand 

type CreateOrchestratorActivityCommand struct {
	Properties *OrchestratorActivity `protobuf:"bytes,3,opt,name=properties,proto3" json:"properties,omitempty"`
}

func (*CreateOrchestratorActivityCommand) Descriptor 

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

func (*CreateOrchestratorActivityCommand) GetProperties 

func (m *CreateOrchestratorActivityCommand) GetProperties() *OrchestratorActivity

func (*CreateOrchestratorActivityCommand) Marshal 

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

func (*CreateOrchestratorActivityCommand) MarshalTo 

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

func (*CreateOrchestratorActivityCommand) MarshalToSizedBuffer 

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

func (*CreateOrchestratorActivityCommand) ProtoMessage 

func (*CreateOrchestratorActivityCommand) ProtoMessage()

func (*CreateOrchestratorActivityCommand) Reset 

func (m *CreateOrchestratorActivityCommand) Reset()

func (*CreateOrchestratorActivityCommand) Size 

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

func (*CreateOrchestratorActivityCommand) String 

func (m *CreateOrchestratorActivityCommand) String() string

func (*CreateOrchestratorActivityCommand) Unmarshal 

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

func (*CreateOrchestratorActivityCommand) XXX_DiscardUnknown 

func (m *CreateOrchestratorActivityCommand) XXX_DiscardUnknown()

func (*CreateOrchestratorActivityCommand) XXX_Marshal 

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

func (*CreateOrchestratorActivityCommand) XXX_Merge 

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

func (*CreateOrchestratorActivityCommand) XXX_Size 

func (m *CreateOrchestratorActivityCommand) XXX_Size() int

func (*CreateOrchestratorActivityCommand) XXX_Unmarshal 

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

type CreateOrchestratorActivityManyRequest 

type CreateOrchestratorActivityManyRequest struct {
	Create  []*CreateOrchestratorActivityCommand `protobuf:"bytes,1,rep,name=create,proto3" json:"create,omitempty"`
	Connect []*basepb.GetQuery                   `protobuf:"bytes,2,rep,name=connect,proto3" json:"connect,omitempty"`
}

func (*CreateOrchestratorActivityManyRequest) Descriptor 

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

func (*CreateOrchestratorActivityManyRequest) GetConnect 

func (m *CreateOrchestratorActivityManyRequest) GetConnect() []*basepb.GetQuery

func (*CreateOrchestratorActivityManyRequest) GetCreate 

func (m *CreateOrchestratorActivityManyRequest) GetCreate() []*CreateOrchestratorActivityCommand

func (*CreateOrchestratorActivityManyRequest) Marshal 

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

func (*CreateOrchestratorActivityManyRequest) MarshalTo 

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

func (*CreateOrchestratorActivityManyRequest) MarshalToSizedBuffer 

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

func (*CreateOrchestratorActivityManyRequest) ProtoMessage 

func (*CreateOrchestratorActivityManyRequest) ProtoMessage()

func (*CreateOrchestratorActivityManyRequest) Reset 

func (m *CreateOrchestratorActivityManyRequest) Reset()

func (*CreateOrchestratorActivityManyRequest) Size 

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

func (*CreateOrchestratorActivityManyRequest) String 

func (m *CreateOrchestratorActivityManyRequest) String() string

func (*CreateOrchestratorActivityManyRequest) Unmarshal 

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

func (*CreateOrchestratorActivityManyRequest) XXX_DiscardUnknown 

func (m *CreateOrchestratorActivityManyRequest) XXX_DiscardUnknown()

func (*CreateOrchestratorActivityManyRequest) XXX_Marshal 

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

func (*CreateOrchestratorActivityManyRequest) XXX_Merge 

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

func (*CreateOrchestratorActivityManyRequest) XXX_Size 

func (m *CreateOrchestratorActivityManyRequest) XXX_Size() int

func (*CreateOrchestratorActivityManyRequest) XXX_Unmarshal 

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

type CreateOrchestratorWorkflowCommand 

type CreateOrchestratorWorkflowCommand struct {
	Properties *OrchestratorWorkflow `protobuf:"bytes,3,opt,name=properties,proto3" json:"properties,omitempty"`
}

func (*CreateOrchestratorWorkflowCommand) Descriptor 

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

func (*CreateOrchestratorWorkflowCommand) GetProperties 

func (m *CreateOrchestratorWorkflowCommand) GetProperties() *OrchestratorWorkflow

func (*CreateOrchestratorWorkflowCommand) Marshal 

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

func (*CreateOrchestratorWorkflowCommand) MarshalTo 

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

func (*CreateOrchestratorWorkflowCommand) MarshalToSizedBuffer 

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

func (*CreateOrchestratorWorkflowCommand) ProtoMessage 

func (*CreateOrchestratorWorkflowCommand) ProtoMessage()

func (*CreateOrchestratorWorkflowCommand) Reset 

func (m *CreateOrchestratorWorkflowCommand) Reset()

func (*CreateOrchestratorWorkflowCommand) Size 

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

func (*CreateOrchestratorWorkflowCommand) String 

func (m *CreateOrchestratorWorkflowCommand) String() string

func (*CreateOrchestratorWorkflowCommand) Unmarshal 

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

func (*CreateOrchestratorWorkflowCommand) XXX_DiscardUnknown 

func (m *CreateOrchestratorWorkflowCommand) XXX_DiscardUnknown()

func (*CreateOrchestratorWorkflowCommand) XXX_Marshal 

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

func (*CreateOrchestratorWorkflowCommand) XXX_Merge 

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

func (*CreateOrchestratorWorkflowCommand) XXX_Size 

func (m *CreateOrchestratorWorkflowCommand) XXX_Size() int

func (*CreateOrchestratorWorkflowCommand) XXX_Unmarshal 

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

type CreateOrchestratorWorkflowManyRequest 

type CreateOrchestratorWorkflowManyRequest struct {
	Create  []*CreateOrchestratorWorkflowCommand `protobuf:"bytes,1,rep,name=create,proto3" json:"create,omitempty"`
	Connect []*basepb.GetQuery                   `protobuf:"bytes,2,rep,name=connect,proto3" json:"connect,omitempty"`
}

func (*CreateOrchestratorWorkflowManyRequest) Descriptor 

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

func (*CreateOrchestratorWorkflowManyRequest) GetConnect 

func (m *CreateOrchestratorWorkflowManyRequest) GetConnect() []*basepb.GetQuery

func (*CreateOrchestratorWorkflowManyRequest) GetCreate 

func (m *CreateOrchestratorWorkflowManyRequest) GetCreate() []*CreateOrchestratorWorkflowCommand

func (*CreateOrchestratorWorkflowManyRequest) Marshal 

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

func (*CreateOrchestratorWorkflowManyRequest) MarshalTo 

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

func (*CreateOrchestratorWorkflowManyRequest) MarshalToSizedBuffer 

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

func (*CreateOrchestratorWorkflowManyRequest) ProtoMessage 

func (*CreateOrchestratorWorkflowManyRequest) ProtoMessage()

func (*CreateOrchestratorWorkflowManyRequest) Reset 

func (m *CreateOrchestratorWorkflowManyRequest) Reset()

func (*CreateOrchestratorWorkflowManyRequest) Size 

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

func (*CreateOrchestratorWorkflowManyRequest) String 

func (m *CreateOrchestratorWorkflowManyRequest) String() string

func (*CreateOrchestratorWorkflowManyRequest) Unmarshal 

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

func (*CreateOrchestratorWorkflowManyRequest) XXX_DiscardUnknown 

func (m *CreateOrchestratorWorkflowManyRequest) XXX_DiscardUnknown()

func (*CreateOrchestratorWorkflowManyRequest) XXX_Marshal 

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

func (*CreateOrchestratorWorkflowManyRequest) XXX_Merge 

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

func (*CreateOrchestratorWorkflowManyRequest) XXX_Size 

func (m *CreateOrchestratorWorkflowManyRequest) XXX_Size() int

func (*CreateOrchestratorWorkflowManyRequest) XXX_Unmarshal 

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

type OrchestratorActivity 

type OrchestratorActivity struct {
	ID                     string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OrchestratorWorkflow   *OrchestratorWorkflow `protobuf:"bytes,2,opt,name=orchestratorWorkflow,proto3" json:"orchestratorWorkflow,omitempty" db:"orchestrator_workflow_id"`
	OrchestratorWorkflowID string                `` /* 127-byte string literal not displayed */
	Step                   int32                 `protobuf:"varint,4,opt,name=step,proto3" json:"step,omitempty" db:"step"`
	Transaction            bool                  `protobuf:"varint,5,opt,name=transaction,proto3" json:"transaction,omitempty" db:"transaction"`
	ArgsJson               string                `protobuf:"bytes,6,opt,name=argsJson,proto3" json:"argsJson,omitempty" db:"args_json"`
	ArgsBinary             []byte                `protobuf:"bytes,7,opt,name=argsBinary,proto3" json:"argsBinary,omitempty" db:"args_binary"`
	ResultJson             string                `protobuf:"bytes,8,opt,name=resultJson,proto3" json:"resultJson,omitempty" db:"result_json"`
	ResultBinary           []byte                `protobuf:"bytes,9,opt,name=resultBinary,proto3" json:"resultBinary,omitempty" db:"result_binary"`
	State                  string                `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty" db:"state"`
	CreatedAt              *timestamp.Timestamp  `protobuf:"bytes,101,opt,name=createdAt,proto3" json:"createdAt,omitempty" db:"created_at"`
	UpdatedAt              *timestamp.Timestamp  `protobuf:"bytes,102,opt,name=updatedAt,proto3" json:"updatedAt,omitempty" db:"updated_at"`
	ExternalModule         string                `protobuf:"bytes,103,opt,name=externalModule,proto3" json:"externalModule,omitempty" db:"external_module"`
	ExternalID             string                `protobuf:"bytes,104,opt,name=externalID,proto3" json:"externalID,omitempty" db:"external_id"`
}

func (*OrchestratorActivity) Descriptor 

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

func (*OrchestratorActivity) GetArgsBinary 

func (m *OrchestratorActivity) GetArgsBinary() []byte

func (*OrchestratorActivity) GetArgsJson 

func (m *OrchestratorActivity) GetArgsJson() string

func (*OrchestratorActivity) GetCreatedAt 

func (m *OrchestratorActivity) GetCreatedAt() *timestamp.Timestamp

func (*OrchestratorActivity) GetExternalID 

func (m *OrchestratorActivity) GetExternalID() string

func (*OrchestratorActivity) GetExternalModule 

func (m *OrchestratorActivity) GetExternalModule() string

func (*OrchestratorActivity) GetID 

func (m *OrchestratorActivity) GetID() string

func (*OrchestratorActivity) GetOrchestratorWorkflow 

func (m *OrchestratorActivity) GetOrchestratorWorkflow() *OrchestratorWorkflow

func (*OrchestratorActivity) GetOrchestratorWorkflowID 

func (m *OrchestratorActivity) GetOrchestratorWorkflowID() string

func (*OrchestratorActivity) GetResultBinary 

func (m *OrchestratorActivity) GetResultBinary() []byte

func (*OrchestratorActivity) GetResultJson 

func (m *OrchestratorActivity) GetResultJson() string

func (*OrchestratorActivity) GetState 

func (m *OrchestratorActivity) GetState() string

func (*OrchestratorActivity) GetStep 

func (m *OrchestratorActivity) GetStep() int32

func (*OrchestratorActivity) GetTransaction 

func (m *OrchestratorActivity) GetTransaction() bool

func (*OrchestratorActivity) GetUpdatedAt 

func (m *OrchestratorActivity) GetUpdatedAt() *timestamp.Timestamp

func (*OrchestratorActivity) Marshal 

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

func (*OrchestratorActivity) MarshalTo 

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

func (*OrchestratorActivity) MarshalToSizedBuffer 

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

func (*OrchestratorActivity) ProtoMessage 

func (*OrchestratorActivity) ProtoMessage()

func (*OrchestratorActivity) Reset 

func (m *OrchestratorActivity) Reset()

func (*OrchestratorActivity) Size 

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

func (*OrchestratorActivity) String 

func (m *OrchestratorActivity) String() string

func (*OrchestratorActivity) Unmarshal 

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

func (*OrchestratorActivity) XXX_DiscardUnknown 

func (m *OrchestratorActivity) XXX_DiscardUnknown()

func (*OrchestratorActivity) XXX_Marshal 

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

func (*OrchestratorActivity) XXX_Merge 

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

func (*OrchestratorActivity) XXX_Size 

func (m *OrchestratorActivity) XXX_Size() int

func (*OrchestratorActivity) XXX_Unmarshal 

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

type OrchestratorActivitys 

type OrchestratorActivitys struct {
	OrchestratorActivitys []*OrchestratorActivity `protobuf:"bytes,1,rep,name=orchestratorActivitys,proto3" json:"orchestratorActivitys,omitempty"`
}

func (*OrchestratorActivitys) Descriptor 

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

func (*OrchestratorActivitys) GetOrchestratorActivitys 

func (m *OrchestratorActivitys) GetOrchestratorActivitys() []*OrchestratorActivity

func (*OrchestratorActivitys) Marshal 

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

func (*OrchestratorActivitys) MarshalTo 

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

func (*OrchestratorActivitys) MarshalToSizedBuffer 

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

func (*OrchestratorActivitys) ProtoMessage 

func (*OrchestratorActivitys) ProtoMessage()

func (*OrchestratorActivitys) Reset 

func (m *OrchestratorActivitys) Reset()

func (*OrchestratorActivitys) Size 

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

func (*OrchestratorActivitys) String 

func (m *OrchestratorActivitys) String() string

func (*OrchestratorActivitys) Unmarshal 

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

func (*OrchestratorActivitys) XXX_DiscardUnknown 

func (m *OrchestratorActivitys) XXX_DiscardUnknown()

func (*OrchestratorActivitys) XXX_Marshal 

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

func (*OrchestratorActivitys) XXX_Merge 

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

func (*OrchestratorActivitys) XXX_Size 

func (m *OrchestratorActivitys) XXX_Size() int

func (*OrchestratorActivitys) XXX_Unmarshal 

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

type OrchestratorWorkflow 

type OrchestratorWorkflow struct {
	ID             string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" db:"name"`
	IdempotencyKey string               `protobuf:"bytes,3,opt,name=idempotencyKey,proto3" json:"idempotencyKey,omitempty" db:"idempotency_key"`
	ArgsJson       string               `protobuf:"bytes,4,opt,name=argsJson,proto3" json:"argsJson,omitempty" db:"args_json"`
	ArgsBinary     []byte               `protobuf:"bytes,5,opt,name=argsBinary,proto3" json:"argsBinary,omitempty" db:"args_binary"`
	ResultJson     string               `protobuf:"bytes,6,opt,name=resultJson,proto3" json:"resultJson,omitempty" db:"result_json"`
	ResultBinary   []byte               `protobuf:"bytes,7,opt,name=resultBinary,proto3" json:"resultBinary,omitempty" db:"result_binary"`
	State          string               `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty" db:"state"`
	CreatedAt      *timestamp.Timestamp `protobuf:"bytes,101,opt,name=createdAt,proto3" json:"createdAt,omitempty" db:"created_at"`
	UpdatedAt      *timestamp.Timestamp `protobuf:"bytes,102,opt,name=updatedAt,proto3" json:"updatedAt,omitempty" db:"updated_at"`
	ExternalModule string               `protobuf:"bytes,103,opt,name=externalModule,proto3" json:"externalModule,omitempty" db:"external_module"`
	ExternalID     string               `protobuf:"bytes,104,opt,name=externalID,proto3" json:"externalID,omitempty" db:"external_id"`
}

func (*OrchestratorWorkflow) Descriptor 

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

func (*OrchestratorWorkflow) GetArgsBinary 

func (m *OrchestratorWorkflow) GetArgsBinary() []byte

func (*OrchestratorWorkflow) GetArgsJson 

func (m *OrchestratorWorkflow) GetArgsJson() string

func (*OrchestratorWorkflow) GetCreatedAt 

func (m *OrchestratorWorkflow) GetCreatedAt() *timestamp.Timestamp

func (*OrchestratorWorkflow) GetExternalID 

func (m *OrchestratorWorkflow) GetExternalID() string

func (*OrchestratorWorkflow) GetExternalModule 

func (m *OrchestratorWorkflow) GetExternalModule() string

func (*OrchestratorWorkflow) GetID 

func (m *OrchestratorWorkflow) GetID() string

func (*OrchestratorWorkflow) GetIdempotencyKey 

func (m *OrchestratorWorkflow) GetIdempotencyKey() string

func (*OrchestratorWorkflow) GetName 

func (m *OrchestratorWorkflow) GetName() string

func (*OrchestratorWorkflow) GetResultBinary 

func (m *OrchestratorWorkflow) GetResultBinary() []byte

func (*OrchestratorWorkflow) GetResultJson 

func (m *OrchestratorWorkflow) GetResultJson() string

func (*OrchestratorWorkflow) GetState 

func (m *OrchestratorWorkflow) GetState() string

func (*OrchestratorWorkflow) GetUpdatedAt 

func (m *OrchestratorWorkflow) GetUpdatedAt() *timestamp.Timestamp

func (*OrchestratorWorkflow) Marshal 

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

func (*OrchestratorWorkflow) MarshalTo 

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

func (*OrchestratorWorkflow) MarshalToSizedBuffer 

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

func (*OrchestratorWorkflow) ProtoMessage 

func (*OrchestratorWorkflow) ProtoMessage()

func (*OrchestratorWorkflow) Reset 

func (m *OrchestratorWorkflow) Reset()

func (*OrchestratorWorkflow) Size 

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

func (*OrchestratorWorkflow) String 

func (m *OrchestratorWorkflow) String() string

func (*OrchestratorWorkflow) Unmarshal 

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

func (*OrchestratorWorkflow) XXX_DiscardUnknown 

func (m *OrchestratorWorkflow) XXX_DiscardUnknown()

func (*OrchestratorWorkflow) XXX_Marshal 

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

func (*OrchestratorWorkflow) XXX_Merge 

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

func (*OrchestratorWorkflow) XXX_Size 

func (m *OrchestratorWorkflow) XXX_Size() int

func (*OrchestratorWorkflow) XXX_Unmarshal 

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

type OrchestratorWorkflows 

type OrchestratorWorkflows struct {
	OrchestratorWorkflows []*OrchestratorWorkflow `protobuf:"bytes,1,rep,name=orchestratorWorkflows,proto3" json:"orchestratorWorkflows,omitempty"`
}

func (*OrchestratorWorkflows) Descriptor 

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

func (*OrchestratorWorkflows) GetOrchestratorWorkflows 

func (m *OrchestratorWorkflows) GetOrchestratorWorkflows() []*OrchestratorWorkflow

func (*OrchestratorWorkflows) Marshal 

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

func (*OrchestratorWorkflows) MarshalTo 

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

func (*OrchestratorWorkflows) MarshalToSizedBuffer 

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

func (*OrchestratorWorkflows) ProtoMessage 

func (*OrchestratorWorkflows) ProtoMessage()

func (*OrchestratorWorkflows) Reset 

func (m *OrchestratorWorkflows) Reset()

func (*OrchestratorWorkflows) Size 

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

func (*OrchestratorWorkflows) String 

func (m *OrchestratorWorkflows) String() string

func (*OrchestratorWorkflows) Unmarshal 

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

func (*OrchestratorWorkflows) XXX_DiscardUnknown 

func (m *OrchestratorWorkflows) XXX_DiscardUnknown()

func (*OrchestratorWorkflows) XXX_Marshal 

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

func (*OrchestratorWorkflows) XXX_Merge 

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

func (*OrchestratorWorkflows) XXX_Size 

func (m *OrchestratorWorkflows) XXX_Size() int

func (*OrchestratorWorkflows) XXX_Unmarshal 

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

type UpdateOrchestratorActivityData 

type UpdateOrchestratorActivityData struct {
	Properties *OrchestratorActivity `protobuf:"bytes,1,opt,name=properties,proto3" json:"properties,omitempty"`
	UpdateMask *fieldmask.FieldMask  `protobuf:"bytes,2,opt,name=updateMask,proto3" json:"updateMask,omitempty"`
}

func (*UpdateOrchestratorActivityData) Descriptor 

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

func (*UpdateOrchestratorActivityData) GetProperties 

func (m *UpdateOrchestratorActivityData) GetProperties() *OrchestratorActivity

func (*UpdateOrchestratorActivityData) GetUpdateMask 

func (m *UpdateOrchestratorActivityData) GetUpdateMask() *fieldmask.FieldMask

func (*UpdateOrchestratorActivityData) Marshal 

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

func (*UpdateOrchestratorActivityData) MarshalTo 

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

func (*UpdateOrchestratorActivityData) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorActivityData) ProtoMessage 

func (*UpdateOrchestratorActivityData) ProtoMessage()

func (*UpdateOrchestratorActivityData) Reset 

func (m *UpdateOrchestratorActivityData) Reset()

func (*UpdateOrchestratorActivityData) Size 

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

func (*UpdateOrchestratorActivityData) String 

func (m *UpdateOrchestratorActivityData) String() string

func (*UpdateOrchestratorActivityData) Unmarshal 

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

func (*UpdateOrchestratorActivityData) XXX_DiscardUnknown 

func (m *UpdateOrchestratorActivityData) XXX_DiscardUnknown()

func (*UpdateOrchestratorActivityData) XXX_Marshal 

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

func (*UpdateOrchestratorActivityData) XXX_Merge 

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

func (*UpdateOrchestratorActivityData) XXX_Size 

func (m *UpdateOrchestratorActivityData) XXX_Size() int

func (*UpdateOrchestratorActivityData) XXX_Unmarshal 

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

type UpdateOrchestratorActivityManyRequest 

type UpdateOrchestratorActivityManyRequest struct {
	Create     []*CreateOrchestratorActivityCommand `protobuf:"bytes,1,rep,name=create,proto3" json:"create,omitempty"`
	Connect    []*basepb.GetQuery                   `protobuf:"bytes,2,rep,name=connect,proto3" json:"connect,omitempty"`
	Set        []*basepb.GetQuery                   `protobuf:"bytes,3,rep,name=set,proto3" json:"set,omitempty"`
	Disconnect []*basepb.GetQuery                   `protobuf:"bytes,4,rep,name=disconnect,proto3" json:"disconnect,omitempty"`
	Delete     []*basepb.GetQuery                   `protobuf:"bytes,5,rep,name=delete,proto3" json:"delete,omitempty"`
	Update     []*UpdateOrchestratorActivityRequest `protobuf:"bytes,6,rep,name=update,proto3" json:"update,omitempty"`
}

func (*UpdateOrchestratorActivityManyRequest) Descriptor 

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

func (*UpdateOrchestratorActivityManyRequest) GetConnect 

func (m *UpdateOrchestratorActivityManyRequest) GetConnect() []*basepb.GetQuery

func (*UpdateOrchestratorActivityManyRequest) GetCreate 

func (m *UpdateOrchestratorActivityManyRequest) GetCreate() []*CreateOrchestratorActivityCommand

func (*UpdateOrchestratorActivityManyRequest) GetDelete 

func (m *UpdateOrchestratorActivityManyRequest) GetDelete() []*basepb.GetQuery

func (*UpdateOrchestratorActivityManyRequest) GetDisconnect 

func (m *UpdateOrchestratorActivityManyRequest) GetDisconnect() []*basepb.GetQuery

func (*UpdateOrchestratorActivityManyRequest) GetSet 

func (m *UpdateOrchestratorActivityManyRequest) GetSet() []*basepb.GetQuery

func (*UpdateOrchestratorActivityManyRequest) GetUpdate 

func (m *UpdateOrchestratorActivityManyRequest) GetUpdate() []*UpdateOrchestratorActivityRequest

func (*UpdateOrchestratorActivityManyRequest) Marshal 

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

func (*UpdateOrchestratorActivityManyRequest) MarshalTo 

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

func (*UpdateOrchestratorActivityManyRequest) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorActivityManyRequest) ProtoMessage 

func (*UpdateOrchestratorActivityManyRequest) ProtoMessage()

func (*UpdateOrchestratorActivityManyRequest) Reset 

func (m *UpdateOrchestratorActivityManyRequest) Reset()

func (*UpdateOrchestratorActivityManyRequest) Size 

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

func (*UpdateOrchestratorActivityManyRequest) String 

func (m *UpdateOrchestratorActivityManyRequest) String() string

func (*UpdateOrchestratorActivityManyRequest) Unmarshal 

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

func (*UpdateOrchestratorActivityManyRequest) XXX_DiscardUnknown 

func (m *UpdateOrchestratorActivityManyRequest) XXX_DiscardUnknown()

func (*UpdateOrchestratorActivityManyRequest) XXX_Marshal 

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

func (*UpdateOrchestratorActivityManyRequest) XXX_Merge 

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

func (*UpdateOrchestratorActivityManyRequest) XXX_Size 

func (m *UpdateOrchestratorActivityManyRequest) XXX_Size() int

func (*UpdateOrchestratorActivityManyRequest) XXX_Unmarshal 

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

type UpdateOrchestratorActivityRequest 

type UpdateOrchestratorActivityRequest struct {
	Where *basepb.GetQuery                `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	Data  *UpdateOrchestratorActivityData `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*UpdateOrchestratorActivityRequest) Descriptor 

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

func (*UpdateOrchestratorActivityRequest) GetData 

func (m *UpdateOrchestratorActivityRequest) GetData() *UpdateOrchestratorActivityData

func (*UpdateOrchestratorActivityRequest) GetWhere 

func (m *UpdateOrchestratorActivityRequest) GetWhere() *basepb.GetQuery

func (*UpdateOrchestratorActivityRequest) Marshal 

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

func (*UpdateOrchestratorActivityRequest) MarshalTo 

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

func (*UpdateOrchestratorActivityRequest) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorActivityRequest) ProtoMessage 

func (*UpdateOrchestratorActivityRequest) ProtoMessage()

func (*UpdateOrchestratorActivityRequest) Reset 

func (m *UpdateOrchestratorActivityRequest) Reset()

func (*UpdateOrchestratorActivityRequest) Size 

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

func (*UpdateOrchestratorActivityRequest) String 

func (m *UpdateOrchestratorActivityRequest) String() string

func (*UpdateOrchestratorActivityRequest) Unmarshal 

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

func (*UpdateOrchestratorActivityRequest) XXX_DiscardUnknown 

func (m *UpdateOrchestratorActivityRequest) XXX_DiscardUnknown()

func (*UpdateOrchestratorActivityRequest) XXX_Marshal 

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

func (*UpdateOrchestratorActivityRequest) XXX_Merge 

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

func (*UpdateOrchestratorActivityRequest) XXX_Size 

func (m *UpdateOrchestratorActivityRequest) XXX_Size() int

func (*UpdateOrchestratorActivityRequest) XXX_Unmarshal 

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

type UpdateOrchestratorWorkflowData 

type UpdateOrchestratorWorkflowData struct {
	Properties *OrchestratorWorkflow `protobuf:"bytes,1,opt,name=properties,proto3" json:"properties,omitempty"`
	UpdateMask *fieldmask.FieldMask  `protobuf:"bytes,2,opt,name=updateMask,proto3" json:"updateMask,omitempty"`
}

func (*UpdateOrchestratorWorkflowData) Descriptor 

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

func (*UpdateOrchestratorWorkflowData) GetProperties 

func (m *UpdateOrchestratorWorkflowData) GetProperties() *OrchestratorWorkflow

func (*UpdateOrchestratorWorkflowData) GetUpdateMask 

func (m *UpdateOrchestratorWorkflowData) GetUpdateMask() *fieldmask.FieldMask

func (*UpdateOrchestratorWorkflowData) Marshal 

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

func (*UpdateOrchestratorWorkflowData) MarshalTo 

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

func (*UpdateOrchestratorWorkflowData) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorWorkflowData) ProtoMessage 

func (*UpdateOrchestratorWorkflowData) ProtoMessage()

func (*UpdateOrchestratorWorkflowData) Reset 

func (m *UpdateOrchestratorWorkflowData) Reset()

func (*UpdateOrchestratorWorkflowData) Size 

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

func (*UpdateOrchestratorWorkflowData) String 

func (m *UpdateOrchestratorWorkflowData) String() string

func (*UpdateOrchestratorWorkflowData) Unmarshal 

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

func (*UpdateOrchestratorWorkflowData) XXX_DiscardUnknown 

func (m *UpdateOrchestratorWorkflowData) XXX_DiscardUnknown()

func (*UpdateOrchestratorWorkflowData) XXX_Marshal 

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

func (*UpdateOrchestratorWorkflowData) XXX_Merge 

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

func (*UpdateOrchestratorWorkflowData) XXX_Size 

func (m *UpdateOrchestratorWorkflowData) XXX_Size() int

func (*UpdateOrchestratorWorkflowData) XXX_Unmarshal 

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

type UpdateOrchestratorWorkflowManyRequest 

type UpdateOrchestratorWorkflowManyRequest struct {
	Create     []*CreateOrchestratorWorkflowCommand `protobuf:"bytes,1,rep,name=create,proto3" json:"create,omitempty"`
	Connect    []*basepb.GetQuery                   `protobuf:"bytes,2,rep,name=connect,proto3" json:"connect,omitempty"`
	Set        []*basepb.GetQuery                   `protobuf:"bytes,3,rep,name=set,proto3" json:"set,omitempty"`
	Disconnect []*basepb.GetQuery                   `protobuf:"bytes,4,rep,name=disconnect,proto3" json:"disconnect,omitempty"`
	Delete     []*basepb.GetQuery                   `protobuf:"bytes,5,rep,name=delete,proto3" json:"delete,omitempty"`
	Update     []*UpdateOrchestratorWorkflowRequest `protobuf:"bytes,6,rep,name=update,proto3" json:"update,omitempty"`
}

func (*UpdateOrchestratorWorkflowManyRequest) Descriptor 

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

func (*UpdateOrchestratorWorkflowManyRequest) GetConnect 

func (m *UpdateOrchestratorWorkflowManyRequest) GetConnect() []*basepb.GetQuery

func (*UpdateOrchestratorWorkflowManyRequest) GetCreate 

func (m *UpdateOrchestratorWorkflowManyRequest) GetCreate() []*CreateOrchestratorWorkflowCommand

func (*UpdateOrchestratorWorkflowManyRequest) GetDelete 

func (m *UpdateOrchestratorWorkflowManyRequest) GetDelete() []*basepb.GetQuery

func (*UpdateOrchestratorWorkflowManyRequest) GetDisconnect 

func (m *UpdateOrchestratorWorkflowManyRequest) GetDisconnect() []*basepb.GetQuery

func (*UpdateOrchestratorWorkflowManyRequest) GetSet 

func (m *UpdateOrchestratorWorkflowManyRequest) GetSet() []*basepb.GetQuery

func (*UpdateOrchestratorWorkflowManyRequest) GetUpdate 

func (m *UpdateOrchestratorWorkflowManyRequest) GetUpdate() []*UpdateOrchestratorWorkflowRequest

func (*UpdateOrchestratorWorkflowManyRequest) Marshal 

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

func (*UpdateOrchestratorWorkflowManyRequest) MarshalTo 

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

func (*UpdateOrchestratorWorkflowManyRequest) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorWorkflowManyRequest) ProtoMessage 

func (*UpdateOrchestratorWorkflowManyRequest) ProtoMessage()

func (*UpdateOrchestratorWorkflowManyRequest) Reset 

func (m *UpdateOrchestratorWorkflowManyRequest) Reset()

func (*UpdateOrchestratorWorkflowManyRequest) Size 

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

func (*UpdateOrchestratorWorkflowManyRequest) String 

func (m *UpdateOrchestratorWorkflowManyRequest) String() string

func (*UpdateOrchestratorWorkflowManyRequest) Unmarshal 

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

func (*UpdateOrchestratorWorkflowManyRequest) XXX_DiscardUnknown 

func (m *UpdateOrchestratorWorkflowManyRequest) XXX_DiscardUnknown()

func (*UpdateOrchestratorWorkflowManyRequest) XXX_Marshal 

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

func (*UpdateOrchestratorWorkflowManyRequest) XXX_Merge 

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

func (*UpdateOrchestratorWorkflowManyRequest) XXX_Size 

func (m *UpdateOrchestratorWorkflowManyRequest) XXX_Size() int

func (*UpdateOrchestratorWorkflowManyRequest) XXX_Unmarshal 

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

type UpdateOrchestratorWorkflowRequest 

type UpdateOrchestratorWorkflowRequest struct {
	Where *basepb.GetQuery                `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	Data  *UpdateOrchestratorWorkflowData `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*UpdateOrchestratorWorkflowRequest) Descriptor 

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

func (*UpdateOrchestratorWorkflowRequest) GetData 

func (m *UpdateOrchestratorWorkflowRequest) GetData() *UpdateOrchestratorWorkflowData

func (*UpdateOrchestratorWorkflowRequest) GetWhere 

func (m *UpdateOrchestratorWorkflowRequest) GetWhere() *basepb.GetQuery

func (*UpdateOrchestratorWorkflowRequest) Marshal 

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

func (*UpdateOrchestratorWorkflowRequest) MarshalTo 

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

func (*UpdateOrchestratorWorkflowRequest) MarshalToSizedBuffer 

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

func (*UpdateOrchestratorWorkflowRequest) ProtoMessage 

func (*UpdateOrchestratorWorkflowRequest) ProtoMessage()

func (*UpdateOrchestratorWorkflowRequest) Reset 

func (m *UpdateOrchestratorWorkflowRequest) Reset()

func (*UpdateOrchestratorWorkflowRequest) Size 

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

func (*UpdateOrchestratorWorkflowRequest) String 

func (m *UpdateOrchestratorWorkflowRequest) String() string

func (*UpdateOrchestratorWorkflowRequest) Unmarshal 

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

func (*UpdateOrchestratorWorkflowRequest) XXX_DiscardUnknown 

func (m *UpdateOrchestratorWorkflowRequest) XXX_DiscardUnknown()

func (*UpdateOrchestratorWorkflowRequest) XXX_Marshal 

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

func (*UpdateOrchestratorWorkflowRequest) XXX_Merge 

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

func (*UpdateOrchestratorWorkflowRequest) XXX_Size 

func (m *UpdateOrchestratorWorkflowRequest) XXX_Size() int

func (*UpdateOrchestratorWorkflowRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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