Documentation ¶
Index ¶
- Variables
- func RegisterDirektivIngressServer(s grpc.ServiceRegistrar, srv DirektivIngressServer)
- type AddNamespaceRequest
- func (*AddNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddNamespaceRequest) GetName() string
- func (*AddNamespaceRequest) ProtoMessage()
- func (x *AddNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *AddNamespaceRequest) Reset()
- func (x *AddNamespaceRequest) String() string
- type AddNamespaceResponse
- func (*AddNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddNamespaceResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *AddNamespaceResponse) GetName() string
- func (*AddNamespaceResponse) ProtoMessage()
- func (x *AddNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *AddNamespaceResponse) Reset()
- func (x *AddNamespaceResponse) String() string
- type AddWorkflowRequest
- func (*AddWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddWorkflowRequest) GetActive() bool
- func (x *AddWorkflowRequest) GetLogToEvents() string
- func (x *AddWorkflowRequest) GetNamespace() string
- func (x *AddWorkflowRequest) GetWorkflow() []byte
- func (*AddWorkflowRequest) ProtoMessage()
- func (x *AddWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *AddWorkflowRequest) Reset()
- func (x *AddWorkflowRequest) String() string
- type AddWorkflowResponse
- func (*AddWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddWorkflowResponse) GetActive() bool
- func (x *AddWorkflowResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *AddWorkflowResponse) GetId() string
- func (x *AddWorkflowResponse) GetRevision() int32
- func (x *AddWorkflowResponse) GetUid() string
- func (*AddWorkflowResponse) ProtoMessage()
- func (x *AddWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *AddWorkflowResponse) Reset()
- func (x *AddWorkflowResponse) String() string
- type BroadcastEventRequest
- func (*BroadcastEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastEventRequest) GetCloudevent() []byte
- func (x *BroadcastEventRequest) GetNamespace() string
- func (x *BroadcastEventRequest) GetTimer() int64
- func (*BroadcastEventRequest) ProtoMessage()
- func (x *BroadcastEventRequest) ProtoReflect() protoreflect.Message
- func (x *BroadcastEventRequest) Reset()
- func (x *BroadcastEventRequest) String() string
- type CancelWorkflowInstanceRequest
- func (*CancelWorkflowInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelWorkflowInstanceRequest) GetId() string
- func (*CancelWorkflowInstanceRequest) ProtoMessage()
- func (x *CancelWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CancelWorkflowInstanceRequest) Reset()
- func (x *CancelWorkflowInstanceRequest) String() string
- type DeleteNamespaceRequest
- func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNamespaceRequest) GetName() string
- func (*DeleteNamespaceRequest) ProtoMessage()
- func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceRequest) Reset()
- func (x *DeleteNamespaceRequest) String() string
- type DeleteNamespaceResponse
- func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNamespaceResponse) GetName() string
- func (*DeleteNamespaceResponse) ProtoMessage()
- func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceResponse) Reset()
- func (x *DeleteNamespaceResponse) String() string
- type DeleteSecretRequest
- func (*DeleteSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSecretRequest) GetName() string
- func (x *DeleteSecretRequest) GetNamespace() string
- func (*DeleteSecretRequest) ProtoMessage()
- func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSecretRequest) Reset()
- func (x *DeleteSecretRequest) String() string
- type DeleteWorkflowRequest
- func (*DeleteWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWorkflowRequest) GetUid() string
- func (*DeleteWorkflowRequest) ProtoMessage()
- func (x *DeleteWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteWorkflowRequest) Reset()
- func (x *DeleteWorkflowRequest) String() string
- type DeleteWorkflowResponse
- func (*DeleteWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWorkflowResponse) GetUid() string
- func (*DeleteWorkflowResponse) ProtoMessage()
- func (x *DeleteWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteWorkflowResponse) Reset()
- func (x *DeleteWorkflowResponse) String() string
- type DirektivIngressClient
- type DirektivIngressServer
- type DirektivIngress_GetNamespaceVariableClient
- type DirektivIngress_GetNamespaceVariableServer
- type DirektivIngress_GetWorkflowVariableClient
- type DirektivIngress_GetWorkflowVariableServer
- type DirektivIngress_SetNamespaceVariableClient
- type DirektivIngress_SetNamespaceVariableServer
- type DirektivIngress_SetWorkflowVariableClient
- type DirektivIngress_SetWorkflowVariableServer
- type DirektivIngress_WatchWorkflowInstanceLogsClient
- type DirektivIngress_WatchWorkflowInstanceLogsServer
- type GetInstancesByWorkflowRequest
- func (*GetInstancesByWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstancesByWorkflowRequest) GetLimit() int32
- func (x *GetInstancesByWorkflowRequest) GetNamespace() string
- func (x *GetInstancesByWorkflowRequest) GetOffset() int32
- func (x *GetInstancesByWorkflowRequest) GetWorkflow() string
- func (*GetInstancesByWorkflowRequest) ProtoMessage()
- func (x *GetInstancesByWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *GetInstancesByWorkflowRequest) Reset()
- func (x *GetInstancesByWorkflowRequest) String() string
- type GetInstancesByWorkflowResponse
- func (*GetInstancesByWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstancesByWorkflowResponse) GetLimit() int32
- func (x *GetInstancesByWorkflowResponse) GetOffset() int32
- func (x *GetInstancesByWorkflowResponse) GetWorkflowInstances() []*GetInstancesByWorkflowResponse_WorkflowInstance
- func (*GetInstancesByWorkflowResponse) ProtoMessage()
- func (x *GetInstancesByWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *GetInstancesByWorkflowResponse) Reset()
- func (x *GetInstancesByWorkflowResponse) String() string
- type GetInstancesByWorkflowResponse_WorkflowInstance
- func (*GetInstancesByWorkflowResponse_WorkflowInstance) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetBeginTime() *timestamp.Timestamp
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetId() string
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetStatus() string
- func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoMessage()
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) ProtoReflect() protoreflect.Message
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) Reset()
- func (x *GetInstancesByWorkflowResponse_WorkflowInstance) String() string
- type GetNamespaceLogsRequest
- func (*GetNamespaceLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceLogsRequest) GetLimit() int32
- func (x *GetNamespaceLogsRequest) GetNamespace() string
- func (x *GetNamespaceLogsRequest) GetOffset() int32
- func (*GetNamespaceLogsRequest) ProtoMessage()
- func (x *GetNamespaceLogsRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceLogsRequest) Reset()
- func (x *GetNamespaceLogsRequest) String() string
- type GetNamespaceLogsResponse
- func (*GetNamespaceLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceLogsResponse) GetLimit() int32
- func (x *GetNamespaceLogsResponse) GetNamespaceLogs() []*GetNamespaceLogsResponse_NamespaceLog
- func (x *GetNamespaceLogsResponse) GetOffset() int32
- func (*GetNamespaceLogsResponse) ProtoMessage()
- func (x *GetNamespaceLogsResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceLogsResponse) Reset()
- func (x *GetNamespaceLogsResponse) String() string
- type GetNamespaceLogsResponse_NamespaceLog
- func (*GetNamespaceLogsResponse_NamespaceLog) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceLogsResponse_NamespaceLog) GetContext() map[string]string
- func (x *GetNamespaceLogsResponse_NamespaceLog) GetId() string
- func (x *GetNamespaceLogsResponse_NamespaceLog) GetLevel() string
- func (x *GetNamespaceLogsResponse_NamespaceLog) GetMessage() string
- func (x *GetNamespaceLogsResponse_NamespaceLog) GetTimestamp() *timestamp.Timestamp
- func (*GetNamespaceLogsResponse_NamespaceLog) ProtoMessage()
- func (x *GetNamespaceLogsResponse_NamespaceLog) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceLogsResponse_NamespaceLog) Reset()
- func (x *GetNamespaceLogsResponse_NamespaceLog) String() string
- type GetNamespaceVariableRequest
- func (*GetNamespaceVariableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceVariableRequest) GetKey() string
- func (x *GetNamespaceVariableRequest) GetNamespace() string
- func (*GetNamespaceVariableRequest) ProtoMessage()
- func (x *GetNamespaceVariableRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceVariableRequest) Reset()
- func (x *GetNamespaceVariableRequest) String() string
- type GetNamespaceVariableResponse
- func (*GetNamespaceVariableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceVariableResponse) GetChunkSize() int64
- func (x *GetNamespaceVariableResponse) GetTotalSize() int64
- func (x *GetNamespaceVariableResponse) GetValue() []byte
- func (*GetNamespaceVariableResponse) ProtoMessage()
- func (x *GetNamespaceVariableResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceVariableResponse) Reset()
- func (x *GetNamespaceVariableResponse) String() string
- type GetNamespacesRequest
- func (*GetNamespacesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespacesRequest) GetLimit() int32
- func (x *GetNamespacesRequest) GetOffset() int32
- func (*GetNamespacesRequest) ProtoMessage()
- func (x *GetNamespacesRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespacesRequest) Reset()
- func (x *GetNamespacesRequest) String() string
- type GetNamespacesResponse
- func (*GetNamespacesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespacesResponse) GetLimit() int32
- func (x *GetNamespacesResponse) GetNamespaces() []*GetNamespacesResponse_Namespace
- func (x *GetNamespacesResponse) GetOffset() int32
- func (*GetNamespacesResponse) ProtoMessage()
- func (x *GetNamespacesResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespacesResponse) Reset()
- func (x *GetNamespacesResponse) String() string
- type GetNamespacesResponse_Namespace
- func (*GetNamespacesResponse_Namespace) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespacesResponse_Namespace) GetCreatedAt() *timestamp.Timestamp
- func (x *GetNamespacesResponse_Namespace) GetName() string
- func (*GetNamespacesResponse_Namespace) ProtoMessage()
- func (x *GetNamespacesResponse_Namespace) ProtoReflect() protoreflect.Message
- func (x *GetNamespacesResponse_Namespace) Reset()
- func (x *GetNamespacesResponse_Namespace) String() string
- type GetSecretsRequest
- type GetSecretsResponse
- func (*GetSecretsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSecretsResponse) GetSecrets() []*GetSecretsResponse_Secret
- func (*GetSecretsResponse) ProtoMessage()
- func (x *GetSecretsResponse) ProtoReflect() protoreflect.Message
- func (x *GetSecretsResponse) Reset()
- func (x *GetSecretsResponse) String() string
- type GetSecretsResponse_Secret
- func (*GetSecretsResponse_Secret) Descriptor() ([]byte, []int)deprecated
- func (x *GetSecretsResponse_Secret) GetName() string
- func (*GetSecretsResponse_Secret) ProtoMessage()
- func (x *GetSecretsResponse_Secret) ProtoReflect() protoreflect.Message
- func (x *GetSecretsResponse_Secret) Reset()
- func (x *GetSecretsResponse_Secret) String() string
- type GetWorkflowByNameRequest
- func (*GetWorkflowByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByNameRequest) GetGetReferences() bool
- func (x *GetWorkflowByNameRequest) GetName() string
- func (x *GetWorkflowByNameRequest) GetNamespace() string
- func (*GetWorkflowByNameRequest) ProtoMessage()
- func (x *GetWorkflowByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByNameRequest) Reset()
- func (x *GetWorkflowByNameRequest) String() string
- type GetWorkflowByNameResponse
- func (*GetWorkflowByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByNameResponse) GetActive() bool
- func (x *GetWorkflowByNameResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *GetWorkflowByNameResponse) GetDescription() string
- func (x *GetWorkflowByNameResponse) GetLogToEvents() string
- func (x *GetWorkflowByNameResponse) GetName() string
- func (x *GetWorkflowByNameResponse) GetReferences() *GetWorkflowByNameResponse_References
- func (x *GetWorkflowByNameResponse) GetRevision() int32
- func (x *GetWorkflowByNameResponse) GetUid() string
- func (x *GetWorkflowByNameResponse) GetWorkflow() []byte
- func (*GetWorkflowByNameResponse) ProtoMessage()
- func (x *GetWorkflowByNameResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByNameResponse) Reset()
- func (x *GetWorkflowByNameResponse) String() string
- type GetWorkflowByNameResponse_References
- func (*GetWorkflowByNameResponse_References) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByNameResponse_References) GetSecrets() []*GetWorkflowByNameResponse_References_Secret
- func (x *GetWorkflowByNameResponse_References) GetVariables() []*GetWorkflowByNameResponse_References_Variable
- func (*GetWorkflowByNameResponse_References) ProtoMessage()
- func (x *GetWorkflowByNameResponse_References) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByNameResponse_References) Reset()
- func (x *GetWorkflowByNameResponse_References) String() string
- type GetWorkflowByNameResponse_References_Secret
- func (*GetWorkflowByNameResponse_References_Secret) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByNameResponse_References_Secret) GetKey() string
- func (*GetWorkflowByNameResponse_References_Secret) ProtoMessage()
- func (x *GetWorkflowByNameResponse_References_Secret) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByNameResponse_References_Secret) Reset()
- func (x *GetWorkflowByNameResponse_References_Secret) String() string
- type GetWorkflowByNameResponse_References_Variable
- func (*GetWorkflowByNameResponse_References_Variable) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByNameResponse_References_Variable) GetKey() string
- func (x *GetWorkflowByNameResponse_References_Variable) GetOperations() []string
- func (x *GetWorkflowByNameResponse_References_Variable) GetScope() string
- func (*GetWorkflowByNameResponse_References_Variable) ProtoMessage()
- func (x *GetWorkflowByNameResponse_References_Variable) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByNameResponse_References_Variable) Reset()
- func (x *GetWorkflowByNameResponse_References_Variable) String() string
- type GetWorkflowByUidRequest
- func (*GetWorkflowByUidRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByUidRequest) GetGetReferences() bool
- func (x *GetWorkflowByUidRequest) GetUid() string
- func (*GetWorkflowByUidRequest) ProtoMessage()
- func (x *GetWorkflowByUidRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByUidRequest) Reset()
- func (x *GetWorkflowByUidRequest) String() string
- type GetWorkflowByUidResponse
- func (*GetWorkflowByUidResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByUidResponse) GetActive() bool
- func (x *GetWorkflowByUidResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *GetWorkflowByUidResponse) GetDescription() string
- func (x *GetWorkflowByUidResponse) GetId() string
- func (x *GetWorkflowByUidResponse) GetLogToEvents() string
- func (x *GetWorkflowByUidResponse) GetReferences() *GetWorkflowByUidResponse_References
- func (x *GetWorkflowByUidResponse) GetRevision() int32
- func (x *GetWorkflowByUidResponse) GetUid() string
- func (x *GetWorkflowByUidResponse) GetWorkflow() []byte
- func (*GetWorkflowByUidResponse) ProtoMessage()
- func (x *GetWorkflowByUidResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByUidResponse) Reset()
- func (x *GetWorkflowByUidResponse) String() string
- type GetWorkflowByUidResponse_References
- func (*GetWorkflowByUidResponse_References) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByUidResponse_References) GetSecrets() []*GetWorkflowByUidResponse_References_Secret
- func (x *GetWorkflowByUidResponse_References) GetVariables() []*GetWorkflowByUidResponse_References_Variable
- func (*GetWorkflowByUidResponse_References) ProtoMessage()
- func (x *GetWorkflowByUidResponse_References) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByUidResponse_References) Reset()
- func (x *GetWorkflowByUidResponse_References) String() string
- type GetWorkflowByUidResponse_References_Secret
- func (*GetWorkflowByUidResponse_References_Secret) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByUidResponse_References_Secret) GetKey() string
- func (*GetWorkflowByUidResponse_References_Secret) ProtoMessage()
- func (x *GetWorkflowByUidResponse_References_Secret) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByUidResponse_References_Secret) Reset()
- func (x *GetWorkflowByUidResponse_References_Secret) String() string
- type GetWorkflowByUidResponse_References_Variable
- func (*GetWorkflowByUidResponse_References_Variable) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByUidResponse_References_Variable) GetKey() string
- func (x *GetWorkflowByUidResponse_References_Variable) GetOperations() []string
- func (x *GetWorkflowByUidResponse_References_Variable) GetScope() string
- func (*GetWorkflowByUidResponse_References_Variable) ProtoMessage()
- func (x *GetWorkflowByUidResponse_References_Variable) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByUidResponse_References_Variable) Reset()
- func (x *GetWorkflowByUidResponse_References_Variable) String() string
- type GetWorkflowInstanceLogsRequest
- func (*GetWorkflowInstanceLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceLogsRequest) GetInstanceId() string
- func (x *GetWorkflowInstanceLogsRequest) GetLimit() int32
- func (x *GetWorkflowInstanceLogsRequest) GetOffset() int32
- func (*GetWorkflowInstanceLogsRequest) ProtoMessage()
- func (x *GetWorkflowInstanceLogsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceLogsRequest) Reset()
- func (x *GetWorkflowInstanceLogsRequest) String() string
- type GetWorkflowInstanceLogsResponse
- func (*GetWorkflowInstanceLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceLogsResponse) GetLimit() int32
- func (x *GetWorkflowInstanceLogsResponse) GetOffset() int32
- func (x *GetWorkflowInstanceLogsResponse) GetWorkflowInstanceLogs() []*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog
- func (*GetWorkflowInstanceLogsResponse) ProtoMessage()
- func (x *GetWorkflowInstanceLogsResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceLogsResponse) Reset()
- func (x *GetWorkflowInstanceLogsResponse) String() string
- type GetWorkflowInstanceLogsResponse_WorkflowInstanceLog
- func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext() map[string]string
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId() string
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel() string
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage() string
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp() *timestamp.Timestamp
- func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage()
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset()
- func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) String() string
- type GetWorkflowInstanceRequest
- func (*GetWorkflowInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceRequest) GetId() string
- func (*GetWorkflowInstanceRequest) ProtoMessage()
- func (x *GetWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceRequest) Reset()
- func (x *GetWorkflowInstanceRequest) String() string
- type GetWorkflowInstanceResponse
- func (*GetWorkflowInstanceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstanceResponse) GetBeginTime() *timestamp.Timestamp
- func (x *GetWorkflowInstanceResponse) GetEndTime() *timestamp.Timestamp
- func (x *GetWorkflowInstanceResponse) GetErrorCode() string
- func (x *GetWorkflowInstanceResponse) GetErrorMessage() string
- func (x *GetWorkflowInstanceResponse) GetFlow() []string
- func (x *GetWorkflowInstanceResponse) GetId() string
- func (x *GetWorkflowInstanceResponse) GetInput() []byte
- func (x *GetWorkflowInstanceResponse) GetInvokedBy() string
- func (x *GetWorkflowInstanceResponse) GetOutput() []byte
- func (x *GetWorkflowInstanceResponse) GetRevision() int32
- func (x *GetWorkflowInstanceResponse) GetStatus() string
- func (*GetWorkflowInstanceResponse) ProtoMessage()
- func (x *GetWorkflowInstanceResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstanceResponse) Reset()
- func (x *GetWorkflowInstanceResponse) String() string
- type GetWorkflowInstancesRequest
- func (*GetWorkflowInstancesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstancesRequest) GetLimit() int32
- func (x *GetWorkflowInstancesRequest) GetNamespace() string
- func (x *GetWorkflowInstancesRequest) GetOffset() int32
- func (*GetWorkflowInstancesRequest) ProtoMessage()
- func (x *GetWorkflowInstancesRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstancesRequest) Reset()
- func (x *GetWorkflowInstancesRequest) String() string
- type GetWorkflowInstancesResponse
- func (*GetWorkflowInstancesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstancesResponse) GetLimit() int32
- func (x *GetWorkflowInstancesResponse) GetOffset() int32
- func (x *GetWorkflowInstancesResponse) GetWorkflowInstances() []*GetWorkflowInstancesResponse_WorkflowInstance
- func (*GetWorkflowInstancesResponse) ProtoMessage()
- func (x *GetWorkflowInstancesResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstancesResponse) Reset()
- func (x *GetWorkflowInstancesResponse) String() string
- type GetWorkflowInstancesResponse_WorkflowInstance
- func (*GetWorkflowInstancesResponse_WorkflowInstance) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime() *timestamp.Timestamp
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetId() string
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetStatus() string
- func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage()
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) Reset()
- func (x *GetWorkflowInstancesResponse_WorkflowInstance) String() string
- type GetWorkflowVariableRequest
- func (*GetWorkflowVariableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVariableRequest) GetKey() string
- func (x *GetWorkflowVariableRequest) GetWorkflowUid() string
- func (*GetWorkflowVariableRequest) ProtoMessage()
- func (x *GetWorkflowVariableRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVariableRequest) Reset()
- func (x *GetWorkflowVariableRequest) String() string
- type GetWorkflowVariableResponse
- func (*GetWorkflowVariableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowVariableResponse) GetChunkSize() int64
- func (x *GetWorkflowVariableResponse) GetTotalSize() int64
- func (x *GetWorkflowVariableResponse) GetValue() []byte
- func (*GetWorkflowVariableResponse) ProtoMessage()
- func (x *GetWorkflowVariableResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowVariableResponse) Reset()
- func (x *GetWorkflowVariableResponse) String() string
- type GetWorkflowsRequest
- func (*GetWorkflowsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowsRequest) GetLimit() int32
- func (x *GetWorkflowsRequest) GetNamespace() string
- func (x *GetWorkflowsRequest) GetOffset() int32
- func (*GetWorkflowsRequest) ProtoMessage()
- func (x *GetWorkflowsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowsRequest) Reset()
- func (x *GetWorkflowsRequest) String() string
- type GetWorkflowsResponse
- func (*GetWorkflowsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowsResponse) GetLimit() int32
- func (x *GetWorkflowsResponse) GetOffset() int32
- func (x *GetWorkflowsResponse) GetTotal() int32
- func (x *GetWorkflowsResponse) GetWorkflows() []*GetWorkflowsResponse_Workflow
- func (*GetWorkflowsResponse) ProtoMessage()
- func (x *GetWorkflowsResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowsResponse) Reset()
- func (x *GetWorkflowsResponse) String() string
- type GetWorkflowsResponse_Workflow
- func (*GetWorkflowsResponse_Workflow) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowsResponse_Workflow) GetActive() bool
- func (x *GetWorkflowsResponse_Workflow) GetCreatedAt() *timestamp.Timestamp
- func (x *GetWorkflowsResponse_Workflow) GetDescription() string
- func (x *GetWorkflowsResponse_Workflow) GetId() string
- func (x *GetWorkflowsResponse_Workflow) GetLogToEvents() string
- func (x *GetWorkflowsResponse_Workflow) GetRevision() int32
- func (x *GetWorkflowsResponse_Workflow) GetUid() string
- func (*GetWorkflowsResponse_Workflow) ProtoMessage()
- func (x *GetWorkflowsResponse_Workflow) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowsResponse_Workflow) Reset()
- func (x *GetWorkflowsResponse_Workflow) String() string
- type InvokeWorkflowRequest
- func (*InvokeWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeWorkflowRequest) GetInput() []byte
- func (x *InvokeWorkflowRequest) GetName() string
- func (x *InvokeWorkflowRequest) GetNamespace() string
- func (x *InvokeWorkflowRequest) GetWait() bool
- func (*InvokeWorkflowRequest) ProtoMessage()
- func (x *InvokeWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *InvokeWorkflowRequest) Reset()
- func (x *InvokeWorkflowRequest) String() string
- type InvokeWorkflowResponse
- func (*InvokeWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeWorkflowResponse) GetErrorCode() string
- func (x *InvokeWorkflowResponse) GetErrorMsg() string
- func (x *InvokeWorkflowResponse) GetInstanceId() string
- func (x *InvokeWorkflowResponse) GetOutput() []byte
- func (*InvokeWorkflowResponse) ProtoMessage()
- func (x *InvokeWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *InvokeWorkflowResponse) Reset()
- func (x *InvokeWorkflowResponse) String() string
- type ListNamespaceVariablesRequest
- func (*ListNamespaceVariablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespaceVariablesRequest) GetNamespace() string
- func (*ListNamespaceVariablesRequest) ProtoMessage()
- func (x *ListNamespaceVariablesRequest) ProtoReflect() protoreflect.Message
- func (x *ListNamespaceVariablesRequest) Reset()
- func (x *ListNamespaceVariablesRequest) String() string
- type ListNamespaceVariablesResponse
- func (*ListNamespaceVariablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespaceVariablesResponse) GetVariables() []*ListNamespaceVariablesResponse_Variable
- func (*ListNamespaceVariablesResponse) ProtoMessage()
- func (x *ListNamespaceVariablesResponse) ProtoReflect() protoreflect.Message
- func (x *ListNamespaceVariablesResponse) Reset()
- func (x *ListNamespaceVariablesResponse) String() string
- type ListNamespaceVariablesResponse_Variable
- func (*ListNamespaceVariablesResponse_Variable) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespaceVariablesResponse_Variable) GetName() string
- func (x *ListNamespaceVariablesResponse_Variable) GetSize() int64
- func (*ListNamespaceVariablesResponse_Variable) ProtoMessage()
- func (x *ListNamespaceVariablesResponse_Variable) ProtoReflect() protoreflect.Message
- func (x *ListNamespaceVariablesResponse_Variable) Reset()
- func (x *ListNamespaceVariablesResponse_Variable) String() string
- type ListWorkflowVariablesRequest
- func (*ListWorkflowVariablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowVariablesRequest) GetWorkflowUid() string
- func (*ListWorkflowVariablesRequest) ProtoMessage()
- func (x *ListWorkflowVariablesRequest) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowVariablesRequest) Reset()
- func (x *ListWorkflowVariablesRequest) String() string
- type ListWorkflowVariablesResponse
- func (*ListWorkflowVariablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowVariablesResponse) GetVariables() []*ListWorkflowVariablesResponse_Variable
- func (*ListWorkflowVariablesResponse) ProtoMessage()
- func (x *ListWorkflowVariablesResponse) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowVariablesResponse) Reset()
- func (x *ListWorkflowVariablesResponse) String() string
- type ListWorkflowVariablesResponse_Variable
- func (*ListWorkflowVariablesResponse_Variable) Descriptor() ([]byte, []int)deprecated
- func (x *ListWorkflowVariablesResponse_Variable) GetName() string
- func (x *ListWorkflowVariablesResponse_Variable) GetSize() int64
- func (*ListWorkflowVariablesResponse_Variable) ProtoMessage()
- func (x *ListWorkflowVariablesResponse_Variable) ProtoReflect() protoreflect.Message
- func (x *ListWorkflowVariablesResponse_Variable) Reset()
- func (x *ListWorkflowVariablesResponse_Variable) String() string
- type MeanOutcomes
- func (*MeanOutcomes) Descriptor() ([]byte, []int)deprecated
- func (x *MeanOutcomes) GetFailure() float32
- func (x *MeanOutcomes) GetSuccess() float32
- func (x *MeanOutcomes) GetTransitions() map[string]float32
- func (*MeanOutcomes) ProtoMessage()
- func (x *MeanOutcomes) ProtoReflect() protoreflect.Message
- func (x *MeanOutcomes) Reset()
- func (x *MeanOutcomes) String() string
- type Outcomes
- func (*Outcomes) Descriptor() ([]byte, []int)deprecated
- func (x *Outcomes) GetFailure() int32
- func (x *Outcomes) GetSuccess() int32
- func (x *Outcomes) GetTransitions() map[string]int32
- func (*Outcomes) ProtoMessage()
- func (x *Outcomes) ProtoReflect() protoreflect.Message
- func (x *Outcomes) Reset()
- func (x *Outcomes) String() string
- type SetNamespaceVariableRequest
- func (*SetNamespaceVariableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetNamespaceVariableRequest) GetChunkSize() int64
- func (x *SetNamespaceVariableRequest) GetKey() string
- func (x *SetNamespaceVariableRequest) GetNamespace() string
- func (x *SetNamespaceVariableRequest) GetTotalSize() int64
- func (x *SetNamespaceVariableRequest) GetValue() []byte
- func (*SetNamespaceVariableRequest) ProtoMessage()
- func (x *SetNamespaceVariableRequest) ProtoReflect() protoreflect.Message
- func (x *SetNamespaceVariableRequest) Reset()
- func (x *SetNamespaceVariableRequest) String() string
- type SetWorkflowVariableRequest
- func (*SetWorkflowVariableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetWorkflowVariableRequest) GetChunkSize() int64
- func (x *SetWorkflowVariableRequest) GetKey() string
- func (x *SetWorkflowVariableRequest) GetTotalSize() int64
- func (x *SetWorkflowVariableRequest) GetValue() []byte
- func (x *SetWorkflowVariableRequest) GetWorkflowUid() string
- func (*SetWorkflowVariableRequest) ProtoMessage()
- func (x *SetWorkflowVariableRequest) ProtoReflect() protoreflect.Message
- func (x *SetWorkflowVariableRequest) Reset()
- func (x *SetWorkflowVariableRequest) String() string
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetFailureRate() float32
- func (x *State) GetInvokers() map[string]int32
- func (x *State) GetInvokersRepresentation() map[string]float32
- func (x *State) GetMeanExecutionsPerInstance() int32
- func (x *State) GetMeanMillisecondsPerInstance() int32
- func (x *State) GetMeanOutcomes() *MeanOutcomes
- func (x *State) GetMeanRetries() float32
- func (x *State) GetName() string
- func (x *State) GetOutcomes() *Outcomes
- func (x *State) GetSuccessRate() float32
- func (x *State) GetTotalExecutions() int32
- func (x *State) GetTotalFailures() int32
- func (x *State) GetTotalMilliseconds() int32
- func (x *State) GetTotalRetries() int32
- func (x *State) GetTotalSuccesses() int32
- func (x *State) GetUnhandledErrors() map[string]int32
- func (x *State) GetUnhandledErrorsRepresentation() map[string]float32
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- type StoreSecretRequest
- func (*StoreSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreSecretRequest) GetData() []byte
- func (x *StoreSecretRequest) GetName() string
- func (x *StoreSecretRequest) GetNamespace() string
- func (*StoreSecretRequest) ProtoMessage()
- func (x *StoreSecretRequest) ProtoReflect() protoreflect.Message
- func (x *StoreSecretRequest) Reset()
- func (x *StoreSecretRequest) String() string
- type UnimplementedDirektivIngressServer
- func (UnimplementedDirektivIngressServer) AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error)
- func (UnimplementedDirektivIngressServer) AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
- func (UnimplementedDirektivIngressServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) GetInstancesByWorkflow(context.Context, *GetInstancesByWorkflowRequest) (*GetInstancesByWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) GetNamespaceLogs(context.Context, *GetNamespaceLogsRequest) (*GetNamespaceLogsResponse, error)
- func (UnimplementedDirektivIngressServer) GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivIngress_GetNamespaceVariableServer) error
- func (UnimplementedDirektivIngressServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
- func (UnimplementedDirektivIngressServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*GetWorkflowByNameResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivIngress_GetWorkflowVariableServer) error
- func (UnimplementedDirektivIngressServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
- func (UnimplementedDirektivIngressServer) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) ListNamespaceVariables(context.Context, *ListNamespaceVariablesRequest) (*ListNamespaceVariablesResponse, error)
- func (UnimplementedDirektivIngressServer) ListWorkflowVariables(context.Context, *ListWorkflowVariablesRequest) (*ListWorkflowVariablesResponse, error)
- func (UnimplementedDirektivIngressServer) SetNamespaceVariable(DirektivIngress_SetNamespaceVariableServer) error
- func (UnimplementedDirektivIngressServer) SetWorkflowVariable(DirektivIngress_SetWorkflowVariableServer) error
- func (UnimplementedDirektivIngressServer) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) WatchWorkflowInstanceLogs(*WatchWorkflowInstanceLogsRequest, ...) error
- func (UnimplementedDirektivIngressServer) WorkflowMetrics(context.Context, *WorkflowMetricsRequest) (*WorkflowMetricsResponse, error)
- type UnsafeDirektivIngressServer
- type UpdateWorkflowRequest
- func (*UpdateWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateWorkflowRequest) GetActive() bool
- func (x *UpdateWorkflowRequest) GetLogToEvents() string
- func (x *UpdateWorkflowRequest) GetRevision() int32
- func (x *UpdateWorkflowRequest) GetUid() string
- func (x *UpdateWorkflowRequest) GetWorkflow() []byte
- func (*UpdateWorkflowRequest) ProtoMessage()
- func (x *UpdateWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateWorkflowRequest) Reset()
- func (x *UpdateWorkflowRequest) String() string
- type UpdateWorkflowResponse
- func (*UpdateWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateWorkflowResponse) GetActive() bool
- func (x *UpdateWorkflowResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *UpdateWorkflowResponse) GetId() string
- func (x *UpdateWorkflowResponse) GetRevision() int32
- func (x *UpdateWorkflowResponse) GetUid() string
- func (*UpdateWorkflowResponse) ProtoMessage()
- func (x *UpdateWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateWorkflowResponse) Reset()
- func (x *UpdateWorkflowResponse) String() string
- type WatchWorkflowInstanceLogsRequest
- func (*WatchWorkflowInstanceLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchWorkflowInstanceLogsRequest) GetInstanceId() string
- func (*WatchWorkflowInstanceLogsRequest) ProtoMessage()
- func (x *WatchWorkflowInstanceLogsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchWorkflowInstanceLogsRequest) Reset()
- func (x *WatchWorkflowInstanceLogsRequest) String() string
- type WatchWorkflowInstanceLogsResponse
- func (*WatchWorkflowInstanceLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchWorkflowInstanceLogsResponse) GetContext() map[string]string
- func (x *WatchWorkflowInstanceLogsResponse) GetId() string
- func (x *WatchWorkflowInstanceLogsResponse) GetLevel() string
- func (x *WatchWorkflowInstanceLogsResponse) GetMessage() string
- func (x *WatchWorkflowInstanceLogsResponse) GetTimestamp() *timestamp.Timestamp
- func (*WatchWorkflowInstanceLogsResponse) ProtoMessage()
- func (x *WatchWorkflowInstanceLogsResponse) ProtoReflect() protoreflect.Message
- func (x *WatchWorkflowInstanceLogsResponse) Reset()
- func (x *WatchWorkflowInstanceLogsResponse) String() string
- type WorkflowMetricsRequest
- func (*WorkflowMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowMetricsRequest) GetNamespace() string
- func (x *WorkflowMetricsRequest) GetSinceTimestamp() *timestamp.Timestamp
- func (x *WorkflowMetricsRequest) GetWorkflow() string
- func (*WorkflowMetricsRequest) ProtoMessage()
- func (x *WorkflowMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *WorkflowMetricsRequest) Reset()
- func (x *WorkflowMetricsRequest) String() string
- type WorkflowMetricsResponse
- func (*WorkflowMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowMetricsResponse) GetErrorCodes() map[string]int32
- func (x *WorkflowMetricsResponse) GetErrorCodesRepresentation() map[string]float32
- func (x *WorkflowMetricsResponse) GetFailedExecutions() int32
- func (x *WorkflowMetricsResponse) GetFailureRate() float32
- func (x *WorkflowMetricsResponse) GetMeanInstanceMilliseconds() int32
- func (x *WorkflowMetricsResponse) GetSampleSize() int32
- func (x *WorkflowMetricsResponse) GetStates() []*State
- func (x *WorkflowMetricsResponse) GetSuccessRate() float32
- func (x *WorkflowMetricsResponse) GetSuccessfulExecutions() int32
- func (x *WorkflowMetricsResponse) GetTotalInstanceMilliseconds() int32
- func (x *WorkflowMetricsResponse) GetTotalInstancesRun() int32
- func (*WorkflowMetricsResponse) ProtoMessage()
- func (x *WorkflowMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *WorkflowMetricsResponse) Reset()
- func (x *WorkflowMetricsResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var DirektivIngress_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ingress.DirektivIngress", HandlerType: (*DirektivIngressServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddNamespace", Handler: _DirektivIngress_AddNamespace_Handler, }, { MethodName: "DeleteNamespace", Handler: _DirektivIngress_DeleteNamespace_Handler, }, { MethodName: "GetNamespaces", Handler: _DirektivIngress_GetNamespaces_Handler, }, { MethodName: "AddWorkflow", Handler: _DirektivIngress_AddWorkflow_Handler, }, { MethodName: "DeleteWorkflow", Handler: _DirektivIngress_DeleteWorkflow_Handler, }, { MethodName: "GetWorkflowByName", Handler: _DirektivIngress_GetWorkflowByName_Handler, }, { MethodName: "GetWorkflowByUid", Handler: _DirektivIngress_GetWorkflowByUid_Handler, }, { MethodName: "GetWorkflowInstance", Handler: _DirektivIngress_GetWorkflowInstance_Handler, }, { MethodName: "GetWorkflowInstances", Handler: _DirektivIngress_GetWorkflowInstances_Handler, }, { MethodName: "GetNamespaceLogs", Handler: _DirektivIngress_GetNamespaceLogs_Handler, }, { MethodName: "GetInstancesByWorkflow", Handler: _DirektivIngress_GetInstancesByWorkflow_Handler, }, { MethodName: "GetWorkflowInstanceLogs", Handler: _DirektivIngress_GetWorkflowInstanceLogs_Handler, }, { MethodName: "CancelWorkflowInstance", Handler: _DirektivIngress_CancelWorkflowInstance_Handler, }, { MethodName: "GetWorkflows", Handler: _DirektivIngress_GetWorkflows_Handler, }, { MethodName: "InvokeWorkflow", Handler: _DirektivIngress_InvokeWorkflow_Handler, }, { MethodName: "UpdateWorkflow", Handler: _DirektivIngress_UpdateWorkflow_Handler, }, { MethodName: "BroadcastEvent", Handler: _DirektivIngress_BroadcastEvent_Handler, }, { MethodName: "GetSecrets", Handler: _DirektivIngress_GetSecrets_Handler, }, { MethodName: "DeleteSecret", Handler: _DirektivIngress_DeleteSecret_Handler, }, { MethodName: "StoreSecret", Handler: _DirektivIngress_StoreSecret_Handler, }, { MethodName: "WorkflowMetrics", Handler: _DirektivIngress_WorkflowMetrics_Handler, }, { MethodName: "ListNamespaceVariables", Handler: _DirektivIngress_ListNamespaceVariables_Handler, }, { MethodName: "ListWorkflowVariables", Handler: _DirektivIngress_ListWorkflowVariables_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchWorkflowInstanceLogs", Handler: _DirektivIngress_WatchWorkflowInstanceLogs_Handler, ServerStreams: true, }, { StreamName: "GetNamespaceVariable", Handler: _DirektivIngress_GetNamespaceVariable_Handler, ServerStreams: true, }, { StreamName: "GetWorkflowVariable", Handler: _DirektivIngress_GetWorkflowVariable_Handler, ServerStreams: true, }, { StreamName: "SetNamespaceVariable", Handler: _DirektivIngress_SetNamespaceVariable_Handler, ClientStreams: true, }, { StreamName: "SetWorkflowVariable", Handler: _DirektivIngress_SetWorkflowVariable_Handler, ClientStreams: true, }, }, Metadata: "pkg/ingress/protocol.proto", }
DirektivIngress_ServiceDesc is the grpc.ServiceDesc for DirektivIngress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_ingress_add_namespace_proto protoreflect.FileDescriptor
var File_pkg_ingress_add_workflow_proto protoreflect.FileDescriptor
var File_pkg_ingress_broadcast_event_proto protoreflect.FileDescriptor
var File_pkg_ingress_cancel_instance_proto protoreflect.FileDescriptor
var File_pkg_ingress_delete_namespace_proto protoreflect.FileDescriptor
var File_pkg_ingress_delete_secret_proto protoreflect.FileDescriptor
var File_pkg_ingress_delete_workflow_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_instance_logs_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_instance_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_instances_by_workflow_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_instances_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_namespace_logs_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_namespace_variable_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_namespaces_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_secrets_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflow_name_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflow_uid_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflow_variable_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflows_proto protoreflect.FileDescriptor
var File_pkg_ingress_invoke_proto protoreflect.FileDescriptor
var File_pkg_ingress_list_namespace_variables_proto protoreflect.FileDescriptor
var File_pkg_ingress_list_workflow_variables_proto protoreflect.FileDescriptor
var File_pkg_ingress_protocol_proto protoreflect.FileDescriptor
var File_pkg_ingress_set_namespace_variable_proto protoreflect.FileDescriptor
var File_pkg_ingress_set_workflow_variable_proto protoreflect.FileDescriptor
var File_pkg_ingress_store_secret_proto protoreflect.FileDescriptor
var File_pkg_ingress_update_workflow_proto protoreflect.FileDescriptor
var File_pkg_ingress_watch_instance_logs_proto protoreflect.FileDescriptor
var File_pkg_ingress_workflow_metrics_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDirektivIngressServer ¶
func RegisterDirektivIngressServer(s grpc.ServiceRegistrar, srv DirektivIngressServer)
Types ¶
type AddNamespaceRequest ¶
type AddNamespaceRequest struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*AddNamespaceRequest) Descriptor
deprecated
func (*AddNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddNamespaceRequest.ProtoReflect.Descriptor instead.
func (*AddNamespaceRequest) GetName ¶
func (x *AddNamespaceRequest) GetName() string
func (*AddNamespaceRequest) ProtoMessage ¶
func (*AddNamespaceRequest) ProtoMessage()
func (*AddNamespaceRequest) ProtoReflect ¶
func (x *AddNamespaceRequest) ProtoReflect() protoreflect.Message
func (*AddNamespaceRequest) Reset ¶
func (x *AddNamespaceRequest) Reset()
func (*AddNamespaceRequest) String ¶
func (x *AddNamespaceRequest) String() string
type AddNamespaceResponse ¶
type AddNamespaceResponse struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*AddNamespaceResponse) Descriptor
deprecated
func (*AddNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddNamespaceResponse.ProtoReflect.Descriptor instead.
func (*AddNamespaceResponse) GetCreatedAt ¶
func (x *AddNamespaceResponse) GetCreatedAt() *timestamp.Timestamp
func (*AddNamespaceResponse) GetName ¶
func (x *AddNamespaceResponse) GetName() string
func (*AddNamespaceResponse) ProtoMessage ¶
func (*AddNamespaceResponse) ProtoMessage()
func (*AddNamespaceResponse) ProtoReflect ¶
func (x *AddNamespaceResponse) ProtoReflect() protoreflect.Message
func (*AddNamespaceResponse) Reset ¶
func (x *AddNamespaceResponse) Reset()
func (*AddNamespaceResponse) String ¶
func (x *AddNamespaceResponse) String() string
type AddWorkflowRequest ¶
type AddWorkflowRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Active *bool `protobuf:"varint,2,opt,name=active,proto3,oneof" json:"active,omitempty"` Workflow []byte `protobuf:"bytes,3,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` LogToEvents *string `protobuf:"bytes,4,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"` // contains filtered or unexported fields }
func (*AddWorkflowRequest) Descriptor
deprecated
func (*AddWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddWorkflowRequest.ProtoReflect.Descriptor instead.
func (*AddWorkflowRequest) GetActive ¶
func (x *AddWorkflowRequest) GetActive() bool
func (*AddWorkflowRequest) GetLogToEvents ¶ added in v0.1.3
func (x *AddWorkflowRequest) GetLogToEvents() string
func (*AddWorkflowRequest) GetNamespace ¶
func (x *AddWorkflowRequest) GetNamespace() string
func (*AddWorkflowRequest) GetWorkflow ¶
func (x *AddWorkflowRequest) GetWorkflow() []byte
func (*AddWorkflowRequest) ProtoMessage ¶
func (*AddWorkflowRequest) ProtoMessage()
func (*AddWorkflowRequest) ProtoReflect ¶
func (x *AddWorkflowRequest) ProtoReflect() protoreflect.Message
func (*AddWorkflowRequest) Reset ¶
func (x *AddWorkflowRequest) Reset()
func (*AddWorkflowRequest) String ¶
func (x *AddWorkflowRequest) String() string
type AddWorkflowResponse ¶
type AddWorkflowResponse struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"` Revision *int32 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*AddWorkflowResponse) Descriptor
deprecated
func (*AddWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddWorkflowResponse.ProtoReflect.Descriptor instead.
func (*AddWorkflowResponse) GetActive ¶
func (x *AddWorkflowResponse) GetActive() bool
func (*AddWorkflowResponse) GetCreatedAt ¶
func (x *AddWorkflowResponse) GetCreatedAt() *timestamp.Timestamp
func (*AddWorkflowResponse) GetId ¶
func (x *AddWorkflowResponse) GetId() string
func (*AddWorkflowResponse) GetRevision ¶
func (x *AddWorkflowResponse) GetRevision() int32
func (*AddWorkflowResponse) GetUid ¶
func (x *AddWorkflowResponse) GetUid() string
func (*AddWorkflowResponse) ProtoMessage ¶
func (*AddWorkflowResponse) ProtoMessage()
func (*AddWorkflowResponse) ProtoReflect ¶
func (x *AddWorkflowResponse) ProtoReflect() protoreflect.Message
func (*AddWorkflowResponse) Reset ¶
func (x *AddWorkflowResponse) Reset()
func (*AddWorkflowResponse) String ¶
func (x *AddWorkflowResponse) String() string
type BroadcastEventRequest ¶
type BroadcastEventRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Cloudevent []byte `protobuf:"bytes,2,opt,name=cloudevent,proto3,oneof" json:"cloudevent,omitempty"` Timer *int64 `protobuf:"varint,3,opt,name=timer,proto3,oneof" json:"timer,omitempty"` // contains filtered or unexported fields }
func (*BroadcastEventRequest) Descriptor
deprecated
func (*BroadcastEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastEventRequest.ProtoReflect.Descriptor instead.
func (*BroadcastEventRequest) GetCloudevent ¶
func (x *BroadcastEventRequest) GetCloudevent() []byte
func (*BroadcastEventRequest) GetNamespace ¶
func (x *BroadcastEventRequest) GetNamespace() string
func (*BroadcastEventRequest) GetTimer ¶ added in v0.4.1
func (x *BroadcastEventRequest) GetTimer() int64
func (*BroadcastEventRequest) ProtoMessage ¶
func (*BroadcastEventRequest) ProtoMessage()
func (*BroadcastEventRequest) ProtoReflect ¶
func (x *BroadcastEventRequest) ProtoReflect() protoreflect.Message
func (*BroadcastEventRequest) Reset ¶
func (x *BroadcastEventRequest) Reset()
func (*BroadcastEventRequest) String ¶
func (x *BroadcastEventRequest) String() string
type CancelWorkflowInstanceRequest ¶
type CancelWorkflowInstanceRequest struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` // contains filtered or unexported fields }
func (*CancelWorkflowInstanceRequest) Descriptor
deprecated
func (*CancelWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*CancelWorkflowInstanceRequest) GetId ¶
func (x *CancelWorkflowInstanceRequest) GetId() string
func (*CancelWorkflowInstanceRequest) ProtoMessage ¶
func (*CancelWorkflowInstanceRequest) ProtoMessage()
func (*CancelWorkflowInstanceRequest) ProtoReflect ¶
func (x *CancelWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
func (*CancelWorkflowInstanceRequest) Reset ¶
func (x *CancelWorkflowInstanceRequest) Reset()
func (*CancelWorkflowInstanceRequest) String ¶
func (x *CancelWorkflowInstanceRequest) String() string
type DeleteNamespaceRequest ¶
type DeleteNamespaceRequest struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteNamespaceRequest) Descriptor
deprecated
func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.
func (*DeleteNamespaceRequest) GetName ¶
func (x *DeleteNamespaceRequest) GetName() string
func (*DeleteNamespaceRequest) ProtoMessage ¶
func (*DeleteNamespaceRequest) ProtoMessage()
func (*DeleteNamespaceRequest) ProtoReflect ¶
func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
func (*DeleteNamespaceRequest) Reset ¶
func (x *DeleteNamespaceRequest) Reset()
func (*DeleteNamespaceRequest) String ¶
func (x *DeleteNamespaceRequest) String() string
type DeleteNamespaceResponse ¶
type DeleteNamespaceResponse struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteNamespaceResponse) Descriptor
deprecated
func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.
func (*DeleteNamespaceResponse) GetName ¶
func (x *DeleteNamespaceResponse) GetName() string
func (*DeleteNamespaceResponse) ProtoMessage ¶
func (*DeleteNamespaceResponse) ProtoMessage()
func (*DeleteNamespaceResponse) ProtoReflect ¶
func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message
func (*DeleteNamespaceResponse) Reset ¶
func (x *DeleteNamespaceResponse) Reset()
func (*DeleteNamespaceResponse) String ¶
func (x *DeleteNamespaceResponse) String() string
type DeleteSecretRequest ¶
type DeleteSecretRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteSecretRequest) Descriptor
deprecated
func (*DeleteSecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.
func (*DeleteSecretRequest) GetName ¶
func (x *DeleteSecretRequest) GetName() string
func (*DeleteSecretRequest) GetNamespace ¶
func (x *DeleteSecretRequest) GetNamespace() string
func (*DeleteSecretRequest) ProtoMessage ¶
func (*DeleteSecretRequest) ProtoMessage()
func (*DeleteSecretRequest) ProtoReflect ¶
func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
func (*DeleteSecretRequest) Reset ¶
func (x *DeleteSecretRequest) Reset()
func (*DeleteSecretRequest) String ¶
func (x *DeleteSecretRequest) String() string
type DeleteWorkflowRequest ¶
type DeleteWorkflowRequest struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*DeleteWorkflowRequest) Descriptor
deprecated
func (*DeleteWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWorkflowRequest.ProtoReflect.Descriptor instead.
func (*DeleteWorkflowRequest) GetUid ¶
func (x *DeleteWorkflowRequest) GetUid() string
func (*DeleteWorkflowRequest) ProtoMessage ¶
func (*DeleteWorkflowRequest) ProtoMessage()
func (*DeleteWorkflowRequest) ProtoReflect ¶
func (x *DeleteWorkflowRequest) ProtoReflect() protoreflect.Message
func (*DeleteWorkflowRequest) Reset ¶
func (x *DeleteWorkflowRequest) Reset()
func (*DeleteWorkflowRequest) String ¶
func (x *DeleteWorkflowRequest) String() string
type DeleteWorkflowResponse ¶
type DeleteWorkflowResponse struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*DeleteWorkflowResponse) Descriptor
deprecated
func (*DeleteWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWorkflowResponse.ProtoReflect.Descriptor instead.
func (*DeleteWorkflowResponse) GetUid ¶
func (x *DeleteWorkflowResponse) GetUid() string
func (*DeleteWorkflowResponse) ProtoMessage ¶
func (*DeleteWorkflowResponse) ProtoMessage()
func (*DeleteWorkflowResponse) ProtoReflect ¶
func (x *DeleteWorkflowResponse) ProtoReflect() protoreflect.Message
func (*DeleteWorkflowResponse) Reset ¶
func (x *DeleteWorkflowResponse) Reset()
func (*DeleteWorkflowResponse) String ¶
func (x *DeleteWorkflowResponse) String() string
type DirektivIngressClient ¶
type DirektivIngressClient interface { AddNamespace(ctx context.Context, in *AddNamespaceRequest, opts ...grpc.CallOption) (*AddNamespaceResponse, error) DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error) GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, error) AddWorkflow(ctx context.Context, in *AddWorkflowRequest, opts ...grpc.CallOption) (*AddWorkflowResponse, error) DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*DeleteWorkflowResponse, error) GetWorkflowByName(ctx context.Context, in *GetWorkflowByNameRequest, opts ...grpc.CallOption) (*GetWorkflowByNameResponse, error) GetWorkflowByUid(ctx context.Context, in *GetWorkflowByUidRequest, opts ...grpc.CallOption) (*GetWorkflowByUidResponse, error) GetWorkflowInstance(ctx context.Context, in *GetWorkflowInstanceRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceResponse, error) GetWorkflowInstances(ctx context.Context, in *GetWorkflowInstancesRequest, opts ...grpc.CallOption) (*GetWorkflowInstancesResponse, error) GetNamespaceLogs(ctx context.Context, in *GetNamespaceLogsRequest, opts ...grpc.CallOption) (*GetNamespaceLogsResponse, error) GetInstancesByWorkflow(ctx context.Context, in *GetInstancesByWorkflowRequest, opts ...grpc.CallOption) (*GetInstancesByWorkflowResponse, error) GetWorkflowInstanceLogs(ctx context.Context, in *GetWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceLogsResponse, error) WatchWorkflowInstanceLogs(ctx context.Context, in *WatchWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (DirektivIngress_WatchWorkflowInstanceLogsClient, error) CancelWorkflowInstance(ctx context.Context, in *CancelWorkflowInstanceRequest, opts ...grpc.CallOption) (*empty.Empty, error) GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error) InvokeWorkflow(ctx context.Context, in *InvokeWorkflowRequest, opts ...grpc.CallOption) (*InvokeWorkflowResponse, error) UpdateWorkflow(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*UpdateWorkflowResponse, error) BroadcastEvent(ctx context.Context, in *BroadcastEventRequest, opts ...grpc.CallOption) (*empty.Empty, error) GetSecrets(ctx context.Context, in *GetSecretsRequest, opts ...grpc.CallOption) (*GetSecretsResponse, error) DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error) StoreSecret(ctx context.Context, in *StoreSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error) WorkflowMetrics(ctx context.Context, in *WorkflowMetricsRequest, opts ...grpc.CallOption) (*WorkflowMetricsResponse, error) ListNamespaceVariables(ctx context.Context, in *ListNamespaceVariablesRequest, opts ...grpc.CallOption) (*ListNamespaceVariablesResponse, error) ListWorkflowVariables(ctx context.Context, in *ListWorkflowVariablesRequest, opts ...grpc.CallOption) (*ListWorkflowVariablesResponse, error) GetNamespaceVariable(ctx context.Context, in *GetNamespaceVariableRequest, opts ...grpc.CallOption) (DirektivIngress_GetNamespaceVariableClient, error) GetWorkflowVariable(ctx context.Context, in *GetWorkflowVariableRequest, opts ...grpc.CallOption) (DirektivIngress_GetWorkflowVariableClient, error) SetNamespaceVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivIngress_SetNamespaceVariableClient, error) SetWorkflowVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivIngress_SetWorkflowVariableClient, error) }
DirektivIngressClient is the client API for DirektivIngress service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDirektivIngressClient ¶
func NewDirektivIngressClient(cc grpc.ClientConnInterface) DirektivIngressClient
type DirektivIngressServer ¶
type DirektivIngressServer interface { AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error) AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error) GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*GetWorkflowByNameResponse, error) GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error) GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error) GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error) GetNamespaceLogs(context.Context, *GetNamespaceLogsRequest) (*GetNamespaceLogsResponse, error) GetInstancesByWorkflow(context.Context, *GetInstancesByWorkflowRequest) (*GetInstancesByWorkflowResponse, error) GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error) WatchWorkflowInstanceLogs(*WatchWorkflowInstanceLogsRequest, DirektivIngress_WatchWorkflowInstanceLogsServer) error CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error) BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error) DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error) WorkflowMetrics(context.Context, *WorkflowMetricsRequest) (*WorkflowMetricsResponse, error) ListNamespaceVariables(context.Context, *ListNamespaceVariablesRequest) (*ListNamespaceVariablesResponse, error) ListWorkflowVariables(context.Context, *ListWorkflowVariablesRequest) (*ListWorkflowVariablesResponse, error) GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivIngress_GetNamespaceVariableServer) error GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivIngress_GetWorkflowVariableServer) error SetNamespaceVariable(DirektivIngress_SetNamespaceVariableServer) error SetWorkflowVariable(DirektivIngress_SetWorkflowVariableServer) error // contains filtered or unexported methods }
DirektivIngressServer is the server API for DirektivIngress service. All implementations must embed UnimplementedDirektivIngressServer for forward compatibility
type DirektivIngress_GetNamespaceVariableClient ¶ added in v0.2.3
type DirektivIngress_GetNamespaceVariableClient interface { Recv() (*GetNamespaceVariableResponse, error) grpc.ClientStream }
type DirektivIngress_GetNamespaceVariableServer ¶ added in v0.2.3
type DirektivIngress_GetNamespaceVariableServer interface { Send(*GetNamespaceVariableResponse) error grpc.ServerStream }
type DirektivIngress_GetWorkflowVariableClient ¶ added in v0.2.3
type DirektivIngress_GetWorkflowVariableClient interface { Recv() (*GetWorkflowVariableResponse, error) grpc.ClientStream }
type DirektivIngress_GetWorkflowVariableServer ¶ added in v0.2.3
type DirektivIngress_GetWorkflowVariableServer interface { Send(*GetWorkflowVariableResponse) error grpc.ServerStream }
type DirektivIngress_SetNamespaceVariableClient ¶ added in v0.2.3
type DirektivIngress_SetNamespaceVariableClient interface { Send(*SetNamespaceVariableRequest) error CloseAndRecv() (*empty.Empty, error) grpc.ClientStream }
type DirektivIngress_SetNamespaceVariableServer ¶ added in v0.2.3
type DirektivIngress_SetNamespaceVariableServer interface { SendAndClose(*empty.Empty) error Recv() (*SetNamespaceVariableRequest, error) grpc.ServerStream }
type DirektivIngress_SetWorkflowVariableClient ¶ added in v0.2.3
type DirektivIngress_SetWorkflowVariableClient interface { Send(*SetWorkflowVariableRequest) error CloseAndRecv() (*empty.Empty, error) grpc.ClientStream }
type DirektivIngress_SetWorkflowVariableServer ¶ added in v0.2.3
type DirektivIngress_SetWorkflowVariableServer interface { SendAndClose(*empty.Empty) error Recv() (*SetWorkflowVariableRequest, error) grpc.ServerStream }
type DirektivIngress_WatchWorkflowInstanceLogsClient ¶ added in v0.4.1
type DirektivIngress_WatchWorkflowInstanceLogsClient interface { Recv() (*WatchWorkflowInstanceLogsResponse, error) grpc.ClientStream }
type DirektivIngress_WatchWorkflowInstanceLogsServer ¶ added in v0.4.1
type DirektivIngress_WatchWorkflowInstanceLogsServer interface { Send(*WatchWorkflowInstanceLogsResponse) error grpc.ServerStream }
type GetInstancesByWorkflowRequest ¶ added in v0.2.1
type GetInstancesByWorkflowRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Workflow *string `protobuf:"bytes,2,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` Offset *int32 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetInstancesByWorkflowRequest) Descriptor
deprecated
added in
v0.2.1
func (*GetInstancesByWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstancesByWorkflowRequest.ProtoReflect.Descriptor instead.
func (*GetInstancesByWorkflowRequest) GetLimit ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) GetLimit() int32
func (*GetInstancesByWorkflowRequest) GetNamespace ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) GetNamespace() string
func (*GetInstancesByWorkflowRequest) GetOffset ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) GetOffset() int32
func (*GetInstancesByWorkflowRequest) GetWorkflow ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) GetWorkflow() string
func (*GetInstancesByWorkflowRequest) ProtoMessage ¶ added in v0.2.1
func (*GetInstancesByWorkflowRequest) ProtoMessage()
func (*GetInstancesByWorkflowRequest) ProtoReflect ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) ProtoReflect() protoreflect.Message
func (*GetInstancesByWorkflowRequest) Reset ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) Reset()
func (*GetInstancesByWorkflowRequest) String ¶ added in v0.2.1
func (x *GetInstancesByWorkflowRequest) String() string
type GetInstancesByWorkflowResponse ¶ added in v0.2.1
type GetInstancesByWorkflowResponse struct { WorkflowInstances []*GetInstancesByWorkflowResponse_WorkflowInstance `protobuf:"bytes,1,rep,name=workflowInstances,proto3" json:"workflowInstances,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetInstancesByWorkflowResponse) Descriptor
deprecated
added in
v0.2.1
func (*GetInstancesByWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInstancesByWorkflowResponse.ProtoReflect.Descriptor instead.
func (*GetInstancesByWorkflowResponse) GetLimit ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) GetLimit() int32
func (*GetInstancesByWorkflowResponse) GetOffset ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) GetOffset() int32
func (*GetInstancesByWorkflowResponse) GetWorkflowInstances ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) GetWorkflowInstances() []*GetInstancesByWorkflowResponse_WorkflowInstance
func (*GetInstancesByWorkflowResponse) ProtoMessage ¶ added in v0.2.1
func (*GetInstancesByWorkflowResponse) ProtoMessage()
func (*GetInstancesByWorkflowResponse) ProtoReflect ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) ProtoReflect() protoreflect.Message
func (*GetInstancesByWorkflowResponse) Reset ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) Reset()
func (*GetInstancesByWorkflowResponse) String ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse) String() string
type GetInstancesByWorkflowResponse_WorkflowInstance ¶ added in v0.2.1
type GetInstancesByWorkflowResponse_WorkflowInstance struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Status *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"` BeginTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=beginTime,proto3,oneof" json:"beginTime,omitempty"` // contains filtered or unexported fields }
func (*GetInstancesByWorkflowResponse_WorkflowInstance) Descriptor
deprecated
added in
v0.2.1
func (*GetInstancesByWorkflowResponse_WorkflowInstance) Descriptor() ([]byte, []int)
Deprecated: Use GetInstancesByWorkflowResponse_WorkflowInstance.ProtoReflect.Descriptor instead.
func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetBeginTime ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetBeginTime() *timestamp.Timestamp
func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetId ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetId() string
func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetStatus ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) GetStatus() string
func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoMessage ¶ added in v0.2.1
func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoMessage()
func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoReflect ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) ProtoReflect() protoreflect.Message
func (*GetInstancesByWorkflowResponse_WorkflowInstance) Reset ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) Reset()
func (*GetInstancesByWorkflowResponse_WorkflowInstance) String ¶ added in v0.2.1
func (x *GetInstancesByWorkflowResponse_WorkflowInstance) String() string
type GetNamespaceLogsRequest ¶ added in v0.2.5
type GetNamespaceLogsRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceLogsRequest) Descriptor
deprecated
added in
v0.2.5
func (*GetNamespaceLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceLogsRequest.ProtoReflect.Descriptor instead.
func (*GetNamespaceLogsRequest) GetLimit ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) GetLimit() int32
func (*GetNamespaceLogsRequest) GetNamespace ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) GetNamespace() string
func (*GetNamespaceLogsRequest) GetOffset ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) GetOffset() int32
func (*GetNamespaceLogsRequest) ProtoMessage ¶ added in v0.2.5
func (*GetNamespaceLogsRequest) ProtoMessage()
func (*GetNamespaceLogsRequest) ProtoReflect ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) ProtoReflect() protoreflect.Message
func (*GetNamespaceLogsRequest) Reset ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) Reset()
func (*GetNamespaceLogsRequest) String ¶ added in v0.2.5
func (x *GetNamespaceLogsRequest) String() string
type GetNamespaceLogsResponse ¶ added in v0.2.5
type GetNamespaceLogsResponse struct { NamespaceLogs []*GetNamespaceLogsResponse_NamespaceLog `protobuf:"bytes,1,rep,name=namespaceLogs,proto3" json:"namespaceLogs,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceLogsResponse) Descriptor
deprecated
added in
v0.2.5
func (*GetNamespaceLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceLogsResponse.ProtoReflect.Descriptor instead.
func (*GetNamespaceLogsResponse) GetLimit ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) GetLimit() int32
func (*GetNamespaceLogsResponse) GetNamespaceLogs ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) GetNamespaceLogs() []*GetNamespaceLogsResponse_NamespaceLog
func (*GetNamespaceLogsResponse) GetOffset ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) GetOffset() int32
func (*GetNamespaceLogsResponse) ProtoMessage ¶ added in v0.2.5
func (*GetNamespaceLogsResponse) ProtoMessage()
func (*GetNamespaceLogsResponse) ProtoReflect ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) ProtoReflect() protoreflect.Message
func (*GetNamespaceLogsResponse) Reset ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) Reset()
func (*GetNamespaceLogsResponse) String ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse) String() string
type GetNamespaceLogsResponse_NamespaceLog ¶ added in v0.2.5
type GetNamespaceLogsResponse_NamespaceLog struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Level *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"` Message *string `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"` Context map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetNamespaceLogsResponse_NamespaceLog) Descriptor
deprecated
added in
v0.2.5
func (*GetNamespaceLogsResponse_NamespaceLog) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceLogsResponse_NamespaceLog.ProtoReflect.Descriptor instead.
func (*GetNamespaceLogsResponse_NamespaceLog) GetContext ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) GetContext() map[string]string
func (*GetNamespaceLogsResponse_NamespaceLog) GetId ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) GetId() string
func (*GetNamespaceLogsResponse_NamespaceLog) GetLevel ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) GetLevel() string
func (*GetNamespaceLogsResponse_NamespaceLog) GetMessage ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) GetMessage() string
func (*GetNamespaceLogsResponse_NamespaceLog) GetTimestamp ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) GetTimestamp() *timestamp.Timestamp
func (*GetNamespaceLogsResponse_NamespaceLog) ProtoMessage ¶ added in v0.2.5
func (*GetNamespaceLogsResponse_NamespaceLog) ProtoMessage()
func (*GetNamespaceLogsResponse_NamespaceLog) ProtoReflect ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) ProtoReflect() protoreflect.Message
func (*GetNamespaceLogsResponse_NamespaceLog) Reset ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) Reset()
func (*GetNamespaceLogsResponse_NamespaceLog) String ¶ added in v0.2.5
func (x *GetNamespaceLogsResponse_NamespaceLog) String() string
type GetNamespaceVariableRequest ¶ added in v0.2.3
type GetNamespaceVariableRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Key *string `protobuf:"bytes,2,opt,name=key,proto3,oneof" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceVariableRequest) Descriptor
deprecated
added in
v0.2.3
func (*GetNamespaceVariableRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceVariableRequest.ProtoReflect.Descriptor instead.
func (*GetNamespaceVariableRequest) GetKey ¶ added in v0.2.3
func (x *GetNamespaceVariableRequest) GetKey() string
func (*GetNamespaceVariableRequest) GetNamespace ¶ added in v0.2.3
func (x *GetNamespaceVariableRequest) GetNamespace() string
func (*GetNamespaceVariableRequest) ProtoMessage ¶ added in v0.2.3
func (*GetNamespaceVariableRequest) ProtoMessage()
func (*GetNamespaceVariableRequest) ProtoReflect ¶ added in v0.2.3
func (x *GetNamespaceVariableRequest) ProtoReflect() protoreflect.Message
func (*GetNamespaceVariableRequest) Reset ¶ added in v0.2.3
func (x *GetNamespaceVariableRequest) Reset()
func (*GetNamespaceVariableRequest) String ¶ added in v0.2.3
func (x *GetNamespaceVariableRequest) String() string
type GetNamespaceVariableResponse ¶ added in v0.2.3
type GetNamespaceVariableResponse struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"` TotalSize *int64 `protobuf:"varint,2,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"` ChunkSize *int64 `protobuf:"varint,3,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceVariableResponse) Descriptor
deprecated
added in
v0.2.3
func (*GetNamespaceVariableResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceVariableResponse.ProtoReflect.Descriptor instead.
func (*GetNamespaceVariableResponse) GetChunkSize ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) GetChunkSize() int64
func (*GetNamespaceVariableResponse) GetTotalSize ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) GetTotalSize() int64
func (*GetNamespaceVariableResponse) GetValue ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) GetValue() []byte
func (*GetNamespaceVariableResponse) ProtoMessage ¶ added in v0.2.3
func (*GetNamespaceVariableResponse) ProtoMessage()
func (*GetNamespaceVariableResponse) ProtoReflect ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) ProtoReflect() protoreflect.Message
func (*GetNamespaceVariableResponse) Reset ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) Reset()
func (*GetNamespaceVariableResponse) String ¶ added in v0.2.3
func (x *GetNamespaceVariableResponse) String() string
type GetNamespacesRequest ¶
type GetNamespacesRequest struct { Offset *int32 `protobuf:"varint,1,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetNamespacesRequest) Descriptor
deprecated
func (*GetNamespacesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespacesRequest.ProtoReflect.Descriptor instead.
func (*GetNamespacesRequest) GetLimit ¶
func (x *GetNamespacesRequest) GetLimit() int32
func (*GetNamespacesRequest) GetOffset ¶
func (x *GetNamespacesRequest) GetOffset() int32
func (*GetNamespacesRequest) ProtoMessage ¶
func (*GetNamespacesRequest) ProtoMessage()
func (*GetNamespacesRequest) ProtoReflect ¶
func (x *GetNamespacesRequest) ProtoReflect() protoreflect.Message
func (*GetNamespacesRequest) Reset ¶
func (x *GetNamespacesRequest) Reset()
func (*GetNamespacesRequest) String ¶
func (x *GetNamespacesRequest) String() string
type GetNamespacesResponse ¶
type GetNamespacesResponse struct { Namespaces []*GetNamespacesResponse_Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetNamespacesResponse) Descriptor
deprecated
func (*GetNamespacesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespacesResponse.ProtoReflect.Descriptor instead.
func (*GetNamespacesResponse) GetLimit ¶
func (x *GetNamespacesResponse) GetLimit() int32
func (*GetNamespacesResponse) GetNamespaces ¶
func (x *GetNamespacesResponse) GetNamespaces() []*GetNamespacesResponse_Namespace
func (*GetNamespacesResponse) GetOffset ¶
func (x *GetNamespacesResponse) GetOffset() int32
func (*GetNamespacesResponse) ProtoMessage ¶
func (*GetNamespacesResponse) ProtoMessage()
func (*GetNamespacesResponse) ProtoReflect ¶
func (x *GetNamespacesResponse) ProtoReflect() protoreflect.Message
func (*GetNamespacesResponse) Reset ¶
func (x *GetNamespacesResponse) Reset()
func (*GetNamespacesResponse) String ¶
func (x *GetNamespacesResponse) String() string
type GetNamespacesResponse_Namespace ¶
type GetNamespacesResponse_Namespace struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*GetNamespacesResponse_Namespace) Descriptor
deprecated
func (*GetNamespacesResponse_Namespace) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespacesResponse_Namespace.ProtoReflect.Descriptor instead.
func (*GetNamespacesResponse_Namespace) GetCreatedAt ¶
func (x *GetNamespacesResponse_Namespace) GetCreatedAt() *timestamp.Timestamp
func (*GetNamespacesResponse_Namespace) GetName ¶
func (x *GetNamespacesResponse_Namespace) GetName() string
func (*GetNamespacesResponse_Namespace) ProtoMessage ¶
func (*GetNamespacesResponse_Namespace) ProtoMessage()
func (*GetNamespacesResponse_Namespace) ProtoReflect ¶
func (x *GetNamespacesResponse_Namespace) ProtoReflect() protoreflect.Message
func (*GetNamespacesResponse_Namespace) Reset ¶
func (x *GetNamespacesResponse_Namespace) Reset()
func (*GetNamespacesResponse_Namespace) String ¶
func (x *GetNamespacesResponse_Namespace) String() string
type GetSecretsRequest ¶
type GetSecretsRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*GetSecretsRequest) Descriptor
deprecated
func (*GetSecretsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSecretsRequest.ProtoReflect.Descriptor instead.
func (*GetSecretsRequest) GetNamespace ¶
func (x *GetSecretsRequest) GetNamespace() string
func (*GetSecretsRequest) ProtoMessage ¶
func (*GetSecretsRequest) ProtoMessage()
func (*GetSecretsRequest) ProtoReflect ¶
func (x *GetSecretsRequest) ProtoReflect() protoreflect.Message
func (*GetSecretsRequest) Reset ¶
func (x *GetSecretsRequest) Reset()
func (*GetSecretsRequest) String ¶
func (x *GetSecretsRequest) String() string
type GetSecretsResponse ¶
type GetSecretsResponse struct { Secrets []*GetSecretsResponse_Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"` // contains filtered or unexported fields }
func (*GetSecretsResponse) Descriptor
deprecated
func (*GetSecretsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSecretsResponse.ProtoReflect.Descriptor instead.
func (*GetSecretsResponse) GetSecrets ¶
func (x *GetSecretsResponse) GetSecrets() []*GetSecretsResponse_Secret
func (*GetSecretsResponse) ProtoMessage ¶
func (*GetSecretsResponse) ProtoMessage()
func (*GetSecretsResponse) ProtoReflect ¶
func (x *GetSecretsResponse) ProtoReflect() protoreflect.Message
func (*GetSecretsResponse) Reset ¶
func (x *GetSecretsResponse) Reset()
func (*GetSecretsResponse) String ¶
func (x *GetSecretsResponse) String() string
type GetSecretsResponse_Secret ¶
type GetSecretsResponse_Secret struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetSecretsResponse_Secret) Descriptor
deprecated
func (*GetSecretsResponse_Secret) Descriptor() ([]byte, []int)
Deprecated: Use GetSecretsResponse_Secret.ProtoReflect.Descriptor instead.
func (*GetSecretsResponse_Secret) GetName ¶
func (x *GetSecretsResponse_Secret) GetName() string
func (*GetSecretsResponse_Secret) ProtoMessage ¶
func (*GetSecretsResponse_Secret) ProtoMessage()
func (*GetSecretsResponse_Secret) ProtoReflect ¶
func (x *GetSecretsResponse_Secret) ProtoReflect() protoreflect.Message
func (*GetSecretsResponse_Secret) Reset ¶
func (x *GetSecretsResponse_Secret) Reset()
func (*GetSecretsResponse_Secret) String ¶
func (x *GetSecretsResponse_Secret) String() string
type GetWorkflowByNameRequest ¶ added in v0.2.1
type GetWorkflowByNameRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"` GetReferences *bool `protobuf:"varint,3,opt,name=getReferences,proto3,oneof" json:"getReferences,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByNameRequest) Descriptor
deprecated
added in
v0.2.1
func (*GetWorkflowByNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByNameRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowByNameRequest) GetGetReferences ¶ added in v0.3.3
func (x *GetWorkflowByNameRequest) GetGetReferences() bool
func (*GetWorkflowByNameRequest) GetName ¶ added in v0.2.1
func (x *GetWorkflowByNameRequest) GetName() string
func (*GetWorkflowByNameRequest) GetNamespace ¶ added in v0.2.1
func (x *GetWorkflowByNameRequest) GetNamespace() string
func (*GetWorkflowByNameRequest) ProtoMessage ¶ added in v0.2.1
func (*GetWorkflowByNameRequest) ProtoMessage()
func (*GetWorkflowByNameRequest) ProtoReflect ¶ added in v0.2.1
func (x *GetWorkflowByNameRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowByNameRequest) Reset ¶ added in v0.2.1
func (x *GetWorkflowByNameRequest) Reset()
func (*GetWorkflowByNameRequest) String ¶ added in v0.2.1
func (x *GetWorkflowByNameRequest) String() string
type GetWorkflowByNameResponse ¶ added in v0.2.1
type GetWorkflowByNameResponse struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"` Revision *int32 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` Description *string `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"` Workflow []byte `protobuf:"bytes,7,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` LogToEvents *string `protobuf:"bytes,8,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"` References *GetWorkflowByNameResponse_References `protobuf:"bytes,9,opt,name=references,proto3,oneof" json:"references,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByNameResponse) Descriptor
deprecated
added in
v0.2.1
func (*GetWorkflowByNameResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByNameResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowByNameResponse) GetActive ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetActive() bool
func (*GetWorkflowByNameResponse) GetCreatedAt ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetCreatedAt() *timestamp.Timestamp
func (*GetWorkflowByNameResponse) GetDescription ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetDescription() string
func (*GetWorkflowByNameResponse) GetLogToEvents ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetLogToEvents() string
func (*GetWorkflowByNameResponse) GetName ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetName() string
func (*GetWorkflowByNameResponse) GetReferences ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse) GetReferences() *GetWorkflowByNameResponse_References
func (*GetWorkflowByNameResponse) GetRevision ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetRevision() int32
func (*GetWorkflowByNameResponse) GetUid ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetUid() string
func (*GetWorkflowByNameResponse) GetWorkflow ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) GetWorkflow() []byte
func (*GetWorkflowByNameResponse) ProtoMessage ¶ added in v0.2.1
func (*GetWorkflowByNameResponse) ProtoMessage()
func (*GetWorkflowByNameResponse) ProtoReflect ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowByNameResponse) Reset ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) Reset()
func (*GetWorkflowByNameResponse) String ¶ added in v0.2.1
func (x *GetWorkflowByNameResponse) String() string
type GetWorkflowByNameResponse_References ¶ added in v0.3.3
type GetWorkflowByNameResponse_References struct { Secrets []*GetWorkflowByNameResponse_References_Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"` Variables []*GetWorkflowByNameResponse_References_Variable `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByNameResponse_References) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByNameResponse_References) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByNameResponse_References.ProtoReflect.Descriptor instead.
func (*GetWorkflowByNameResponse_References) GetSecrets ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References) GetSecrets() []*GetWorkflowByNameResponse_References_Secret
func (*GetWorkflowByNameResponse_References) GetVariables ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References) GetVariables() []*GetWorkflowByNameResponse_References_Variable
func (*GetWorkflowByNameResponse_References) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByNameResponse_References) ProtoMessage()
func (*GetWorkflowByNameResponse_References) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References) ProtoReflect() protoreflect.Message
func (*GetWorkflowByNameResponse_References) Reset ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References) Reset()
func (*GetWorkflowByNameResponse_References) String ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References) String() string
type GetWorkflowByNameResponse_References_Secret ¶ added in v0.3.3
type GetWorkflowByNameResponse_References_Secret struct { Key *string `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByNameResponse_References_Secret) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByNameResponse_References_Secret) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByNameResponse_References_Secret.ProtoReflect.Descriptor instead.
func (*GetWorkflowByNameResponse_References_Secret) GetKey ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Secret) GetKey() string
func (*GetWorkflowByNameResponse_References_Secret) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByNameResponse_References_Secret) ProtoMessage()
func (*GetWorkflowByNameResponse_References_Secret) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Secret) ProtoReflect() protoreflect.Message
func (*GetWorkflowByNameResponse_References_Secret) Reset ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Secret) Reset()
func (*GetWorkflowByNameResponse_References_Secret) String ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Secret) String() string
type GetWorkflowByNameResponse_References_Variable ¶ added in v0.3.3
type GetWorkflowByNameResponse_References_Variable struct { Key *string `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"` Scope *string `protobuf:"bytes,2,opt,name=scope,proto3,oneof" json:"scope,omitempty"` Operations []string `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByNameResponse_References_Variable) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByNameResponse_References_Variable) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByNameResponse_References_Variable.ProtoReflect.Descriptor instead.
func (*GetWorkflowByNameResponse_References_Variable) GetKey ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) GetKey() string
func (*GetWorkflowByNameResponse_References_Variable) GetOperations ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) GetOperations() []string
func (*GetWorkflowByNameResponse_References_Variable) GetScope ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) GetScope() string
func (*GetWorkflowByNameResponse_References_Variable) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByNameResponse_References_Variable) ProtoMessage()
func (*GetWorkflowByNameResponse_References_Variable) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) ProtoReflect() protoreflect.Message
func (*GetWorkflowByNameResponse_References_Variable) Reset ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) Reset()
func (*GetWorkflowByNameResponse_References_Variable) String ¶ added in v0.3.3
func (x *GetWorkflowByNameResponse_References_Variable) String() string
type GetWorkflowByUidRequest ¶
type GetWorkflowByUidRequest struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` GetReferences *bool `protobuf:"varint,2,opt,name=getReferences,proto3,oneof" json:"getReferences,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidRequest) Descriptor
deprecated
func (*GetWorkflowByUidRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowByUidRequest) GetGetReferences ¶ added in v0.3.3
func (x *GetWorkflowByUidRequest) GetGetReferences() bool
func (*GetWorkflowByUidRequest) GetUid ¶
func (x *GetWorkflowByUidRequest) GetUid() string
func (*GetWorkflowByUidRequest) ProtoMessage ¶
func (*GetWorkflowByUidRequest) ProtoMessage()
func (*GetWorkflowByUidRequest) ProtoReflect ¶
func (x *GetWorkflowByUidRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowByUidRequest) Reset ¶
func (x *GetWorkflowByUidRequest) Reset()
func (*GetWorkflowByUidRequest) String ¶
func (x *GetWorkflowByUidRequest) String() string
type GetWorkflowByUidResponse ¶
type GetWorkflowByUidResponse struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"` Revision *int32 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` Description *string `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"` Workflow []byte `protobuf:"bytes,7,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` LogToEvents *string `protobuf:"bytes,8,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"` References *GetWorkflowByUidResponse_References `protobuf:"bytes,9,opt,name=references,proto3,oneof" json:"references,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidResponse) Descriptor
deprecated
func (*GetWorkflowByUidResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowByUidResponse) GetActive ¶
func (x *GetWorkflowByUidResponse) GetActive() bool
func (*GetWorkflowByUidResponse) GetCreatedAt ¶
func (x *GetWorkflowByUidResponse) GetCreatedAt() *timestamp.Timestamp
func (*GetWorkflowByUidResponse) GetDescription ¶
func (x *GetWorkflowByUidResponse) GetDescription() string
func (*GetWorkflowByUidResponse) GetId ¶
func (x *GetWorkflowByUidResponse) GetId() string
func (*GetWorkflowByUidResponse) GetLogToEvents ¶ added in v0.1.3
func (x *GetWorkflowByUidResponse) GetLogToEvents() string
func (*GetWorkflowByUidResponse) GetReferences ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse) GetReferences() *GetWorkflowByUidResponse_References
func (*GetWorkflowByUidResponse) GetRevision ¶
func (x *GetWorkflowByUidResponse) GetRevision() int32
func (*GetWorkflowByUidResponse) GetUid ¶
func (x *GetWorkflowByUidResponse) GetUid() string
func (*GetWorkflowByUidResponse) GetWorkflow ¶
func (x *GetWorkflowByUidResponse) GetWorkflow() []byte
func (*GetWorkflowByUidResponse) ProtoMessage ¶
func (*GetWorkflowByUidResponse) ProtoMessage()
func (*GetWorkflowByUidResponse) ProtoReflect ¶
func (x *GetWorkflowByUidResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowByUidResponse) Reset ¶
func (x *GetWorkflowByUidResponse) Reset()
func (*GetWorkflowByUidResponse) String ¶
func (x *GetWorkflowByUidResponse) String() string
type GetWorkflowByUidResponse_References ¶ added in v0.3.3
type GetWorkflowByUidResponse_References struct { Secrets []*GetWorkflowByUidResponse_References_Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"` Variables []*GetWorkflowByUidResponse_References_Variable `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidResponse_References) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByUidResponse_References) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidResponse_References.ProtoReflect.Descriptor instead.
func (*GetWorkflowByUidResponse_References) GetSecrets ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References) GetSecrets() []*GetWorkflowByUidResponse_References_Secret
func (*GetWorkflowByUidResponse_References) GetVariables ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References) GetVariables() []*GetWorkflowByUidResponse_References_Variable
func (*GetWorkflowByUidResponse_References) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByUidResponse_References) ProtoMessage()
func (*GetWorkflowByUidResponse_References) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References) ProtoReflect() protoreflect.Message
func (*GetWorkflowByUidResponse_References) Reset ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References) Reset()
func (*GetWorkflowByUidResponse_References) String ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References) String() string
type GetWorkflowByUidResponse_References_Secret ¶ added in v0.3.3
type GetWorkflowByUidResponse_References_Secret struct { Key *string `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidResponse_References_Secret) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByUidResponse_References_Secret) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidResponse_References_Secret.ProtoReflect.Descriptor instead.
func (*GetWorkflowByUidResponse_References_Secret) GetKey ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Secret) GetKey() string
func (*GetWorkflowByUidResponse_References_Secret) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByUidResponse_References_Secret) ProtoMessage()
func (*GetWorkflowByUidResponse_References_Secret) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Secret) ProtoReflect() protoreflect.Message
func (*GetWorkflowByUidResponse_References_Secret) Reset ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Secret) Reset()
func (*GetWorkflowByUidResponse_References_Secret) String ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Secret) String() string
type GetWorkflowByUidResponse_References_Variable ¶ added in v0.3.3
type GetWorkflowByUidResponse_References_Variable struct { Key *string `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"` Scope *string `protobuf:"bytes,2,opt,name=scope,proto3,oneof" json:"scope,omitempty"` Operations []string `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidResponse_References_Variable) Descriptor
deprecated
added in
v0.3.3
func (*GetWorkflowByUidResponse_References_Variable) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidResponse_References_Variable.ProtoReflect.Descriptor instead.
func (*GetWorkflowByUidResponse_References_Variable) GetKey ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) GetKey() string
func (*GetWorkflowByUidResponse_References_Variable) GetOperations ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) GetOperations() []string
func (*GetWorkflowByUidResponse_References_Variable) GetScope ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) GetScope() string
func (*GetWorkflowByUidResponse_References_Variable) ProtoMessage ¶ added in v0.3.3
func (*GetWorkflowByUidResponse_References_Variable) ProtoMessage()
func (*GetWorkflowByUidResponse_References_Variable) ProtoReflect ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) ProtoReflect() protoreflect.Message
func (*GetWorkflowByUidResponse_References_Variable) Reset ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) Reset()
func (*GetWorkflowByUidResponse_References_Variable) String ¶ added in v0.3.3
func (x *GetWorkflowByUidResponse_References_Variable) String() string
type GetWorkflowInstanceLogsRequest ¶
type GetWorkflowInstanceLogsRequest struct { InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstanceLogsRequest) Descriptor
deprecated
func (*GetWorkflowInstanceLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceLogsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceLogsRequest) GetInstanceId ¶
func (x *GetWorkflowInstanceLogsRequest) GetInstanceId() string
func (*GetWorkflowInstanceLogsRequest) GetLimit ¶
func (x *GetWorkflowInstanceLogsRequest) GetLimit() int32
func (*GetWorkflowInstanceLogsRequest) GetOffset ¶
func (x *GetWorkflowInstanceLogsRequest) GetOffset() int32
func (*GetWorkflowInstanceLogsRequest) ProtoMessage ¶
func (*GetWorkflowInstanceLogsRequest) ProtoMessage()
func (*GetWorkflowInstanceLogsRequest) ProtoReflect ¶
func (x *GetWorkflowInstanceLogsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceLogsRequest) Reset ¶
func (x *GetWorkflowInstanceLogsRequest) Reset()
func (*GetWorkflowInstanceLogsRequest) String ¶
func (x *GetWorkflowInstanceLogsRequest) String() string
type GetWorkflowInstanceLogsResponse ¶
type GetWorkflowInstanceLogsResponse struct { WorkflowInstanceLogs []*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog `protobuf:"bytes,1,rep,name=workflowInstanceLogs,proto3" json:"workflowInstanceLogs,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstanceLogsResponse) Descriptor
deprecated
func (*GetWorkflowInstanceLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceLogsResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceLogsResponse) GetLimit ¶
func (x *GetWorkflowInstanceLogsResponse) GetLimit() int32
func (*GetWorkflowInstanceLogsResponse) GetOffset ¶
func (x *GetWorkflowInstanceLogsResponse) GetOffset() int32
func (*GetWorkflowInstanceLogsResponse) GetWorkflowInstanceLogs ¶
func (x *GetWorkflowInstanceLogsResponse) GetWorkflowInstanceLogs() []*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog
func (*GetWorkflowInstanceLogsResponse) ProtoMessage ¶
func (*GetWorkflowInstanceLogsResponse) ProtoMessage()
func (*GetWorkflowInstanceLogsResponse) ProtoReflect ¶
func (x *GetWorkflowInstanceLogsResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceLogsResponse) Reset ¶
func (x *GetWorkflowInstanceLogsResponse) Reset()
func (*GetWorkflowInstanceLogsResponse) String ¶
func (x *GetWorkflowInstanceLogsResponse) String() string
type GetWorkflowInstanceLogsResponse_WorkflowInstanceLog ¶
type GetWorkflowInstanceLogsResponse_WorkflowInstanceLog struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Level *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"` Message *string `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"` Context map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Descriptor
deprecated
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceLogsResponse_WorkflowInstanceLog.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext() map[string]string
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId() string
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel() string
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage() string
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp() *timestamp.Timestamp
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage ¶
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage()
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset()
func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) String ¶
func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) String() string
type GetWorkflowInstanceRequest ¶
type GetWorkflowInstanceRequest struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstanceRequest) Descriptor
deprecated
func (*GetWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceRequest) GetId ¶
func (x *GetWorkflowInstanceRequest) GetId() string
func (*GetWorkflowInstanceRequest) ProtoMessage ¶
func (*GetWorkflowInstanceRequest) ProtoMessage()
func (*GetWorkflowInstanceRequest) ProtoReflect ¶
func (x *GetWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceRequest) Reset ¶
func (x *GetWorkflowInstanceRequest) Reset()
func (*GetWorkflowInstanceRequest) String ¶
func (x *GetWorkflowInstanceRequest) String() string
type GetWorkflowInstanceResponse ¶
type GetWorkflowInstanceResponse struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Status *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"` InvokedBy *string `protobuf:"bytes,3,opt,name=invokedBy,proto3,oneof" json:"invokedBy,omitempty"` Revision *int32 `protobuf:"varint,4,opt,name=revision,proto3,oneof" json:"revision,omitempty"` BeginTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=beginTime,proto3,oneof" json:"beginTime,omitempty"` EndTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=endTime,proto3,oneof" json:"endTime,omitempty"` Flow []string `protobuf:"bytes,7,rep,name=flow,proto3" json:"flow,omitempty"` Input []byte `protobuf:"bytes,8,opt,name=input,proto3,oneof" json:"input,omitempty"` Output []byte `protobuf:"bytes,9,opt,name=output,proto3,oneof" json:"output,omitempty"` ErrorCode *string `protobuf:"bytes,10,opt,name=errorCode,proto3,oneof" json:"errorCode,omitempty"` ErrorMessage *string `protobuf:"bytes,11,opt,name=errorMessage,proto3,oneof" json:"errorMessage,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstanceResponse) Descriptor
deprecated
func (*GetWorkflowInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstanceResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstanceResponse) GetBeginTime ¶
func (x *GetWorkflowInstanceResponse) GetBeginTime() *timestamp.Timestamp
func (*GetWorkflowInstanceResponse) GetEndTime ¶
func (x *GetWorkflowInstanceResponse) GetEndTime() *timestamp.Timestamp
func (*GetWorkflowInstanceResponse) GetErrorCode ¶ added in v0.2.3
func (x *GetWorkflowInstanceResponse) GetErrorCode() string
func (*GetWorkflowInstanceResponse) GetErrorMessage ¶ added in v0.2.3
func (x *GetWorkflowInstanceResponse) GetErrorMessage() string
func (*GetWorkflowInstanceResponse) GetFlow ¶
func (x *GetWorkflowInstanceResponse) GetFlow() []string
func (*GetWorkflowInstanceResponse) GetId ¶
func (x *GetWorkflowInstanceResponse) GetId() string
func (*GetWorkflowInstanceResponse) GetInput ¶
func (x *GetWorkflowInstanceResponse) GetInput() []byte
func (*GetWorkflowInstanceResponse) GetInvokedBy ¶
func (x *GetWorkflowInstanceResponse) GetInvokedBy() string
func (*GetWorkflowInstanceResponse) GetOutput ¶
func (x *GetWorkflowInstanceResponse) GetOutput() []byte
func (*GetWorkflowInstanceResponse) GetRevision ¶
func (x *GetWorkflowInstanceResponse) GetRevision() int32
func (*GetWorkflowInstanceResponse) GetStatus ¶
func (x *GetWorkflowInstanceResponse) GetStatus() string
func (*GetWorkflowInstanceResponse) ProtoMessage ¶
func (*GetWorkflowInstanceResponse) ProtoMessage()
func (*GetWorkflowInstanceResponse) ProtoReflect ¶
func (x *GetWorkflowInstanceResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstanceResponse) Reset ¶
func (x *GetWorkflowInstanceResponse) Reset()
func (*GetWorkflowInstanceResponse) String ¶
func (x *GetWorkflowInstanceResponse) String() string
type GetWorkflowInstancesRequest ¶
type GetWorkflowInstancesRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstancesRequest) Descriptor
deprecated
func (*GetWorkflowInstancesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstancesRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstancesRequest) GetLimit ¶
func (x *GetWorkflowInstancesRequest) GetLimit() int32
func (*GetWorkflowInstancesRequest) GetNamespace ¶
func (x *GetWorkflowInstancesRequest) GetNamespace() string
func (*GetWorkflowInstancesRequest) GetOffset ¶
func (x *GetWorkflowInstancesRequest) GetOffset() int32
func (*GetWorkflowInstancesRequest) ProtoMessage ¶
func (*GetWorkflowInstancesRequest) ProtoMessage()
func (*GetWorkflowInstancesRequest) ProtoReflect ¶
func (x *GetWorkflowInstancesRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstancesRequest) Reset ¶
func (x *GetWorkflowInstancesRequest) Reset()
func (*GetWorkflowInstancesRequest) String ¶
func (x *GetWorkflowInstancesRequest) String() string
type GetWorkflowInstancesResponse ¶
type GetWorkflowInstancesResponse struct { WorkflowInstances []*GetWorkflowInstancesResponse_WorkflowInstance `protobuf:"bytes,1,rep,name=workflowInstances,proto3" json:"workflowInstances,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstancesResponse) Descriptor
deprecated
func (*GetWorkflowInstancesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstancesResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstancesResponse) GetLimit ¶
func (x *GetWorkflowInstancesResponse) GetLimit() int32
func (*GetWorkflowInstancesResponse) GetOffset ¶
func (x *GetWorkflowInstancesResponse) GetOffset() int32
func (*GetWorkflowInstancesResponse) GetWorkflowInstances ¶
func (x *GetWorkflowInstancesResponse) GetWorkflowInstances() []*GetWorkflowInstancesResponse_WorkflowInstance
func (*GetWorkflowInstancesResponse) ProtoMessage ¶
func (*GetWorkflowInstancesResponse) ProtoMessage()
func (*GetWorkflowInstancesResponse) ProtoReflect ¶
func (x *GetWorkflowInstancesResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstancesResponse) Reset ¶
func (x *GetWorkflowInstancesResponse) Reset()
func (*GetWorkflowInstancesResponse) String ¶
func (x *GetWorkflowInstancesResponse) String() string
type GetWorkflowInstancesResponse_WorkflowInstance ¶
type GetWorkflowInstancesResponse_WorkflowInstance struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Status *string `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"` BeginTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=beginTime,proto3,oneof" json:"beginTime,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowInstancesResponse_WorkflowInstance) Descriptor
deprecated
func (*GetWorkflowInstancesResponse_WorkflowInstance) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowInstancesResponse_WorkflowInstance.ProtoReflect.Descriptor instead.
func (*GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime() *timestamp.Timestamp
func (*GetWorkflowInstancesResponse_WorkflowInstance) GetId ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetId() string
func (*GetWorkflowInstancesResponse_WorkflowInstance) GetStatus ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetStatus() string
func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage ¶
func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage()
func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect() protoreflect.Message
func (*GetWorkflowInstancesResponse_WorkflowInstance) Reset ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) Reset()
func (*GetWorkflowInstancesResponse_WorkflowInstance) String ¶
func (x *GetWorkflowInstancesResponse_WorkflowInstance) String() string
type GetWorkflowVariableRequest ¶ added in v0.2.3
type GetWorkflowVariableRequest struct { WorkflowUid *string `protobuf:"bytes,1,opt,name=workflowUid,proto3,oneof" json:"workflowUid,omitempty"` Key *string `protobuf:"bytes,2,opt,name=key,proto3,oneof" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVariableRequest) Descriptor
deprecated
added in
v0.2.3
func (*GetWorkflowVariableRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVariableRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowVariableRequest) GetKey ¶ added in v0.2.3
func (x *GetWorkflowVariableRequest) GetKey() string
func (*GetWorkflowVariableRequest) GetWorkflowUid ¶ added in v0.2.3
func (x *GetWorkflowVariableRequest) GetWorkflowUid() string
func (*GetWorkflowVariableRequest) ProtoMessage ¶ added in v0.2.3
func (*GetWorkflowVariableRequest) ProtoMessage()
func (*GetWorkflowVariableRequest) ProtoReflect ¶ added in v0.2.3
func (x *GetWorkflowVariableRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowVariableRequest) Reset ¶ added in v0.2.3
func (x *GetWorkflowVariableRequest) Reset()
func (*GetWorkflowVariableRequest) String ¶ added in v0.2.3
func (x *GetWorkflowVariableRequest) String() string
type GetWorkflowVariableResponse ¶ added in v0.2.3
type GetWorkflowVariableResponse struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"` TotalSize *int64 `protobuf:"varint,2,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"` ChunkSize *int64 `protobuf:"varint,3,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowVariableResponse) Descriptor
deprecated
added in
v0.2.3
func (*GetWorkflowVariableResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowVariableResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowVariableResponse) GetChunkSize ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) GetChunkSize() int64
func (*GetWorkflowVariableResponse) GetTotalSize ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) GetTotalSize() int64
func (*GetWorkflowVariableResponse) GetValue ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) GetValue() []byte
func (*GetWorkflowVariableResponse) ProtoMessage ¶ added in v0.2.3
func (*GetWorkflowVariableResponse) ProtoMessage()
func (*GetWorkflowVariableResponse) ProtoReflect ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowVariableResponse) Reset ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) Reset()
func (*GetWorkflowVariableResponse) String ¶ added in v0.2.3
func (x *GetWorkflowVariableResponse) String() string
type GetWorkflowsRequest ¶
type GetWorkflowsRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowsRequest) Descriptor
deprecated
func (*GetWorkflowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowsRequest) GetLimit ¶
func (x *GetWorkflowsRequest) GetLimit() int32
func (*GetWorkflowsRequest) GetNamespace ¶
func (x *GetWorkflowsRequest) GetNamespace() string
func (*GetWorkflowsRequest) GetOffset ¶
func (x *GetWorkflowsRequest) GetOffset() int32
func (*GetWorkflowsRequest) ProtoMessage ¶
func (*GetWorkflowsRequest) ProtoMessage()
func (*GetWorkflowsRequest) ProtoReflect ¶
func (x *GetWorkflowsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowsRequest) Reset ¶
func (x *GetWorkflowsRequest) Reset()
func (*GetWorkflowsRequest) String ¶
func (x *GetWorkflowsRequest) String() string
type GetWorkflowsResponse ¶
type GetWorkflowsResponse struct { Workflows []*GetWorkflowsResponse_Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"` Offset *int32 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"` Limit *int32 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"` Total *int32 `protobuf:"varint,4,opt,name=total,proto3,oneof" json:"total,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowsResponse) Descriptor
deprecated
func (*GetWorkflowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowsResponse) GetLimit ¶
func (x *GetWorkflowsResponse) GetLimit() int32
func (*GetWorkflowsResponse) GetOffset ¶
func (x *GetWorkflowsResponse) GetOffset() int32
func (*GetWorkflowsResponse) GetTotal ¶
func (x *GetWorkflowsResponse) GetTotal() int32
func (*GetWorkflowsResponse) GetWorkflows ¶
func (x *GetWorkflowsResponse) GetWorkflows() []*GetWorkflowsResponse_Workflow
func (*GetWorkflowsResponse) ProtoMessage ¶
func (*GetWorkflowsResponse) ProtoMessage()
func (*GetWorkflowsResponse) ProtoReflect ¶
func (x *GetWorkflowsResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowsResponse) Reset ¶
func (x *GetWorkflowsResponse) Reset()
func (*GetWorkflowsResponse) String ¶
func (x *GetWorkflowsResponse) String() string
type GetWorkflowsResponse_Workflow ¶
type GetWorkflowsResponse_Workflow struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"` Revision *int32 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` Description *string `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"` LogToEvents *string `protobuf:"bytes,7,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowsResponse_Workflow) Descriptor
deprecated
func (*GetWorkflowsResponse_Workflow) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowsResponse_Workflow.ProtoReflect.Descriptor instead.
func (*GetWorkflowsResponse_Workflow) GetActive ¶
func (x *GetWorkflowsResponse_Workflow) GetActive() bool
func (*GetWorkflowsResponse_Workflow) GetCreatedAt ¶
func (x *GetWorkflowsResponse_Workflow) GetCreatedAt() *timestamp.Timestamp
func (*GetWorkflowsResponse_Workflow) GetDescription ¶
func (x *GetWorkflowsResponse_Workflow) GetDescription() string
func (*GetWorkflowsResponse_Workflow) GetId ¶
func (x *GetWorkflowsResponse_Workflow) GetId() string
func (*GetWorkflowsResponse_Workflow) GetLogToEvents ¶ added in v0.1.3
func (x *GetWorkflowsResponse_Workflow) GetLogToEvents() string
func (*GetWorkflowsResponse_Workflow) GetRevision ¶
func (x *GetWorkflowsResponse_Workflow) GetRevision() int32
func (*GetWorkflowsResponse_Workflow) GetUid ¶
func (x *GetWorkflowsResponse_Workflow) GetUid() string
func (*GetWorkflowsResponse_Workflow) ProtoMessage ¶
func (*GetWorkflowsResponse_Workflow) ProtoMessage()
func (*GetWorkflowsResponse_Workflow) ProtoReflect ¶
func (x *GetWorkflowsResponse_Workflow) ProtoReflect() protoreflect.Message
func (*GetWorkflowsResponse_Workflow) Reset ¶
func (x *GetWorkflowsResponse_Workflow) Reset()
func (*GetWorkflowsResponse_Workflow) String ¶
func (x *GetWorkflowsResponse_Workflow) String() string
type InvokeWorkflowRequest ¶
type InvokeWorkflowRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"` Input []byte `protobuf:"bytes,3,opt,name=input,proto3,oneof" json:"input,omitempty"` Wait *bool `protobuf:"varint,4,opt,name=wait,proto3,oneof" json:"wait,omitempty"` // contains filtered or unexported fields }
func (*InvokeWorkflowRequest) Descriptor
deprecated
func (*InvokeWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use InvokeWorkflowRequest.ProtoReflect.Descriptor instead.
func (*InvokeWorkflowRequest) GetInput ¶
func (x *InvokeWorkflowRequest) GetInput() []byte
func (*InvokeWorkflowRequest) GetName ¶ added in v0.2.1
func (x *InvokeWorkflowRequest) GetName() string
func (*InvokeWorkflowRequest) GetNamespace ¶
func (x *InvokeWorkflowRequest) GetNamespace() string
func (*InvokeWorkflowRequest) GetWait ¶ added in v0.2.5
func (x *InvokeWorkflowRequest) GetWait() bool
func (*InvokeWorkflowRequest) ProtoMessage ¶
func (*InvokeWorkflowRequest) ProtoMessage()
func (*InvokeWorkflowRequest) ProtoReflect ¶
func (x *InvokeWorkflowRequest) ProtoReflect() protoreflect.Message
func (*InvokeWorkflowRequest) Reset ¶
func (x *InvokeWorkflowRequest) Reset()
func (*InvokeWorkflowRequest) String ¶
func (x *InvokeWorkflowRequest) String() string
type InvokeWorkflowResponse ¶
type InvokeWorkflowResponse struct { InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"` Output []byte `protobuf:"bytes,2,opt,name=output,proto3,oneof" json:"output,omitempty"` ErrorCode *string `protobuf:"bytes,3,opt,name=errorCode,proto3,oneof" json:"errorCode,omitempty"` ErrorMsg *string `protobuf:"bytes,4,opt,name=errorMsg,proto3,oneof" json:"errorMsg,omitempty"` // contains filtered or unexported fields }
func (*InvokeWorkflowResponse) Descriptor
deprecated
func (*InvokeWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use InvokeWorkflowResponse.ProtoReflect.Descriptor instead.
func (*InvokeWorkflowResponse) GetErrorCode ¶ added in v0.3.4
func (x *InvokeWorkflowResponse) GetErrorCode() string
func (*InvokeWorkflowResponse) GetErrorMsg ¶ added in v0.3.4
func (x *InvokeWorkflowResponse) GetErrorMsg() string
func (*InvokeWorkflowResponse) GetInstanceId ¶
func (x *InvokeWorkflowResponse) GetInstanceId() string
func (*InvokeWorkflowResponse) GetOutput ¶ added in v0.2.5
func (x *InvokeWorkflowResponse) GetOutput() []byte
func (*InvokeWorkflowResponse) ProtoMessage ¶
func (*InvokeWorkflowResponse) ProtoMessage()
func (*InvokeWorkflowResponse) ProtoReflect ¶
func (x *InvokeWorkflowResponse) ProtoReflect() protoreflect.Message
func (*InvokeWorkflowResponse) Reset ¶
func (x *InvokeWorkflowResponse) Reset()
func (*InvokeWorkflowResponse) String ¶
func (x *InvokeWorkflowResponse) String() string
type ListNamespaceVariablesRequest ¶ added in v0.2.3
type ListNamespaceVariablesRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ListNamespaceVariablesRequest) Descriptor
deprecated
added in
v0.2.3
func (*ListNamespaceVariablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListNamespaceVariablesRequest.ProtoReflect.Descriptor instead.
func (*ListNamespaceVariablesRequest) GetNamespace ¶ added in v0.2.3
func (x *ListNamespaceVariablesRequest) GetNamespace() string
func (*ListNamespaceVariablesRequest) ProtoMessage ¶ added in v0.2.3
func (*ListNamespaceVariablesRequest) ProtoMessage()
func (*ListNamespaceVariablesRequest) ProtoReflect ¶ added in v0.2.3
func (x *ListNamespaceVariablesRequest) ProtoReflect() protoreflect.Message
func (*ListNamespaceVariablesRequest) Reset ¶ added in v0.2.3
func (x *ListNamespaceVariablesRequest) Reset()
func (*ListNamespaceVariablesRequest) String ¶ added in v0.2.3
func (x *ListNamespaceVariablesRequest) String() string
type ListNamespaceVariablesResponse ¶ added in v0.2.3
type ListNamespaceVariablesResponse struct { Variables []*ListNamespaceVariablesResponse_Variable `protobuf:"bytes,1,rep,name=variables,proto3" json:"variables,omitempty"` // contains filtered or unexported fields }
func (*ListNamespaceVariablesResponse) Descriptor
deprecated
added in
v0.2.3
func (*ListNamespaceVariablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListNamespaceVariablesResponse.ProtoReflect.Descriptor instead.
func (*ListNamespaceVariablesResponse) GetVariables ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse) GetVariables() []*ListNamespaceVariablesResponse_Variable
func (*ListNamespaceVariablesResponse) ProtoMessage ¶ added in v0.2.3
func (*ListNamespaceVariablesResponse) ProtoMessage()
func (*ListNamespaceVariablesResponse) ProtoReflect ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse) ProtoReflect() protoreflect.Message
func (*ListNamespaceVariablesResponse) Reset ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse) Reset()
func (*ListNamespaceVariablesResponse) String ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse) String() string
type ListNamespaceVariablesResponse_Variable ¶ added in v0.2.3
type ListNamespaceVariablesResponse_Variable struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` Size *int64 `protobuf:"varint,2,opt,name=size,proto3,oneof" json:"size,omitempty"` // contains filtered or unexported fields }
func (*ListNamespaceVariablesResponse_Variable) Descriptor
deprecated
added in
v0.2.3
func (*ListNamespaceVariablesResponse_Variable) Descriptor() ([]byte, []int)
Deprecated: Use ListNamespaceVariablesResponse_Variable.ProtoReflect.Descriptor instead.
func (*ListNamespaceVariablesResponse_Variable) GetName ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse_Variable) GetName() string
func (*ListNamespaceVariablesResponse_Variable) GetSize ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse_Variable) GetSize() int64
func (*ListNamespaceVariablesResponse_Variable) ProtoMessage ¶ added in v0.2.3
func (*ListNamespaceVariablesResponse_Variable) ProtoMessage()
func (*ListNamespaceVariablesResponse_Variable) ProtoReflect ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse_Variable) ProtoReflect() protoreflect.Message
func (*ListNamespaceVariablesResponse_Variable) Reset ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse_Variable) Reset()
func (*ListNamespaceVariablesResponse_Variable) String ¶ added in v0.2.3
func (x *ListNamespaceVariablesResponse_Variable) String() string
type ListWorkflowVariablesRequest ¶ added in v0.2.3
type ListWorkflowVariablesRequest struct { WorkflowUid *string `protobuf:"bytes,1,opt,name=workflowUid,proto3,oneof" json:"workflowUid,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowVariablesRequest) Descriptor
deprecated
added in
v0.2.3
func (*ListWorkflowVariablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowVariablesRequest.ProtoReflect.Descriptor instead.
func (*ListWorkflowVariablesRequest) GetWorkflowUid ¶ added in v0.2.3
func (x *ListWorkflowVariablesRequest) GetWorkflowUid() string
func (*ListWorkflowVariablesRequest) ProtoMessage ¶ added in v0.2.3
func (*ListWorkflowVariablesRequest) ProtoMessage()
func (*ListWorkflowVariablesRequest) ProtoReflect ¶ added in v0.2.3
func (x *ListWorkflowVariablesRequest) ProtoReflect() protoreflect.Message
func (*ListWorkflowVariablesRequest) Reset ¶ added in v0.2.3
func (x *ListWorkflowVariablesRequest) Reset()
func (*ListWorkflowVariablesRequest) String ¶ added in v0.2.3
func (x *ListWorkflowVariablesRequest) String() string
type ListWorkflowVariablesResponse ¶ added in v0.2.3
type ListWorkflowVariablesResponse struct { Variables []*ListWorkflowVariablesResponse_Variable `protobuf:"bytes,1,rep,name=variables,proto3" json:"variables,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowVariablesResponse) Descriptor
deprecated
added in
v0.2.3
func (*ListWorkflowVariablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowVariablesResponse.ProtoReflect.Descriptor instead.
func (*ListWorkflowVariablesResponse) GetVariables ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse) GetVariables() []*ListWorkflowVariablesResponse_Variable
func (*ListWorkflowVariablesResponse) ProtoMessage ¶ added in v0.2.3
func (*ListWorkflowVariablesResponse) ProtoMessage()
func (*ListWorkflowVariablesResponse) ProtoReflect ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse) ProtoReflect() protoreflect.Message
func (*ListWorkflowVariablesResponse) Reset ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse) Reset()
func (*ListWorkflowVariablesResponse) String ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse) String() string
type ListWorkflowVariablesResponse_Variable ¶ added in v0.2.3
type ListWorkflowVariablesResponse_Variable struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` Size *int64 `protobuf:"varint,2,opt,name=size,proto3,oneof" json:"size,omitempty"` // contains filtered or unexported fields }
func (*ListWorkflowVariablesResponse_Variable) Descriptor
deprecated
added in
v0.2.3
func (*ListWorkflowVariablesResponse_Variable) Descriptor() ([]byte, []int)
Deprecated: Use ListWorkflowVariablesResponse_Variable.ProtoReflect.Descriptor instead.
func (*ListWorkflowVariablesResponse_Variable) GetName ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse_Variable) GetName() string
func (*ListWorkflowVariablesResponse_Variable) GetSize ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse_Variable) GetSize() int64
func (*ListWorkflowVariablesResponse_Variable) ProtoMessage ¶ added in v0.2.3
func (*ListWorkflowVariablesResponse_Variable) ProtoMessage()
func (*ListWorkflowVariablesResponse_Variable) ProtoReflect ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse_Variable) ProtoReflect() protoreflect.Message
func (*ListWorkflowVariablesResponse_Variable) Reset ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse_Variable) Reset()
func (*ListWorkflowVariablesResponse_Variable) String ¶ added in v0.2.3
func (x *ListWorkflowVariablesResponse_Variable) String() string
type MeanOutcomes ¶ added in v0.2.1
type MeanOutcomes struct { Success *float32 `protobuf:"fixed32,1,opt,name=success,proto3,oneof" json:"success,omitempty"` Failure *float32 `protobuf:"fixed32,2,opt,name=failure,proto3,oneof" json:"failure,omitempty"` Transitions map[string]float32 `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MeanOutcomes) Descriptor
deprecated
added in
v0.2.1
func (*MeanOutcomes) Descriptor() ([]byte, []int)
Deprecated: Use MeanOutcomes.ProtoReflect.Descriptor instead.
func (*MeanOutcomes) GetFailure ¶ added in v0.2.1
func (x *MeanOutcomes) GetFailure() float32
func (*MeanOutcomes) GetSuccess ¶ added in v0.2.1
func (x *MeanOutcomes) GetSuccess() float32
func (*MeanOutcomes) GetTransitions ¶ added in v0.2.1
func (x *MeanOutcomes) GetTransitions() map[string]float32
func (*MeanOutcomes) ProtoMessage ¶ added in v0.2.1
func (*MeanOutcomes) ProtoMessage()
func (*MeanOutcomes) ProtoReflect ¶ added in v0.2.1
func (x *MeanOutcomes) ProtoReflect() protoreflect.Message
func (*MeanOutcomes) Reset ¶ added in v0.2.1
func (x *MeanOutcomes) Reset()
func (*MeanOutcomes) String ¶ added in v0.2.1
func (x *MeanOutcomes) String() string
type Outcomes ¶ added in v0.2.1
type Outcomes struct { Success *int32 `protobuf:"varint,1,opt,name=success,proto3,oneof" json:"success,omitempty"` Failure *int32 `protobuf:"varint,2,opt,name=failure,proto3,oneof" json:"failure,omitempty"` Transitions map[string]int32 `` /* 164-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Outcomes) Descriptor
deprecated
added in
v0.2.1
func (*Outcomes) GetFailure ¶ added in v0.2.1
func (*Outcomes) GetSuccess ¶ added in v0.2.1
func (*Outcomes) GetTransitions ¶ added in v0.2.1
func (*Outcomes) ProtoMessage ¶ added in v0.2.1
func (*Outcomes) ProtoMessage()
func (*Outcomes) ProtoReflect ¶ added in v0.2.1
func (x *Outcomes) ProtoReflect() protoreflect.Message
type SetNamespaceVariableRequest ¶ added in v0.2.3
type SetNamespaceVariableRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Key *string `protobuf:"bytes,2,opt,name=key,proto3,oneof" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"` TotalSize *int64 `protobuf:"varint,4,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"` ChunkSize *int64 `protobuf:"varint,5,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"` // contains filtered or unexported fields }
func (*SetNamespaceVariableRequest) Descriptor
deprecated
added in
v0.2.3
func (*SetNamespaceVariableRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetNamespaceVariableRequest.ProtoReflect.Descriptor instead.
func (*SetNamespaceVariableRequest) GetChunkSize ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) GetChunkSize() int64
func (*SetNamespaceVariableRequest) GetKey ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) GetKey() string
func (*SetNamespaceVariableRequest) GetNamespace ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) GetNamespace() string
func (*SetNamespaceVariableRequest) GetTotalSize ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) GetTotalSize() int64
func (*SetNamespaceVariableRequest) GetValue ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) GetValue() []byte
func (*SetNamespaceVariableRequest) ProtoMessage ¶ added in v0.2.3
func (*SetNamespaceVariableRequest) ProtoMessage()
func (*SetNamespaceVariableRequest) ProtoReflect ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) ProtoReflect() protoreflect.Message
func (*SetNamespaceVariableRequest) Reset ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) Reset()
func (*SetNamespaceVariableRequest) String ¶ added in v0.2.3
func (x *SetNamespaceVariableRequest) String() string
type SetWorkflowVariableRequest ¶ added in v0.2.3
type SetWorkflowVariableRequest struct { WorkflowUid *string `protobuf:"bytes,1,opt,name=workflowUid,proto3,oneof" json:"workflowUid,omitempty"` Key *string `protobuf:"bytes,2,opt,name=key,proto3,oneof" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"` TotalSize *int64 `protobuf:"varint,4,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"` ChunkSize *int64 `protobuf:"varint,5,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"` // contains filtered or unexported fields }
func (*SetWorkflowVariableRequest) Descriptor
deprecated
added in
v0.2.3
func (*SetWorkflowVariableRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetWorkflowVariableRequest.ProtoReflect.Descriptor instead.
func (*SetWorkflowVariableRequest) GetChunkSize ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) GetChunkSize() int64
func (*SetWorkflowVariableRequest) GetKey ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) GetKey() string
func (*SetWorkflowVariableRequest) GetTotalSize ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) GetTotalSize() int64
func (*SetWorkflowVariableRequest) GetValue ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) GetValue() []byte
func (*SetWorkflowVariableRequest) GetWorkflowUid ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) GetWorkflowUid() string
func (*SetWorkflowVariableRequest) ProtoMessage ¶ added in v0.2.3
func (*SetWorkflowVariableRequest) ProtoMessage()
func (*SetWorkflowVariableRequest) ProtoReflect ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) ProtoReflect() protoreflect.Message
func (*SetWorkflowVariableRequest) Reset ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) Reset()
func (*SetWorkflowVariableRequest) String ¶ added in v0.2.3
func (x *SetWorkflowVariableRequest) String() string
type State ¶ added in v0.2.1
type State struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` Invokers map[string]int32 `` /* 158-byte string literal not displayed */ InvokersRepresentation map[string]float32 `` /* 187-byte string literal not displayed */ TotalExecutions *int32 `protobuf:"varint,4,opt,name=totalExecutions,proto3,oneof" json:"totalExecutions,omitempty"` TotalMilliseconds *int32 `protobuf:"varint,5,opt,name=totalMilliseconds,proto3,oneof" json:"totalMilliseconds,omitempty"` TotalSuccesses *int32 `protobuf:"varint,6,opt,name=totalSuccesses,proto3,oneof" json:"totalSuccesses,omitempty"` TotalFailures *int32 `protobuf:"varint,7,opt,name=totalFailures,proto3,oneof" json:"totalFailures,omitempty"` UnhandledErrors map[string]int32 `` /* 172-byte string literal not displayed */ UnhandledErrorsRepresentation map[string]float32 `` /* 201-byte string literal not displayed */ TotalRetries *int32 `protobuf:"varint,10,opt,name=totalRetries,proto3,oneof" json:"totalRetries,omitempty"` Outcomes *Outcomes `protobuf:"bytes,11,opt,name=outcomes,proto3,oneof" json:"outcomes,omitempty"` MeanExecutionsPerInstance *int32 `protobuf:"varint,12,opt,name=meanExecutionsPerInstance,proto3,oneof" json:"meanExecutionsPerInstance,omitempty"` MeanMillisecondsPerInstance *int32 `protobuf:"varint,13,opt,name=meanMillisecondsPerInstance,proto3,oneof" json:"meanMillisecondsPerInstance,omitempty"` SuccessRate *float32 `protobuf:"fixed32,14,opt,name=successRate,proto3,oneof" json:"successRate,omitempty"` FailureRate *float32 `protobuf:"fixed32,15,opt,name=failureRate,proto3,oneof" json:"failureRate,omitempty"` MeanRetries *float32 `protobuf:"fixed32,16,opt,name=meanRetries,proto3,oneof" json:"meanRetries,omitempty"` MeanOutcomes *MeanOutcomes `protobuf:"bytes,17,opt,name=meanOutcomes,proto3,oneof" json:"meanOutcomes,omitempty"` // contains filtered or unexported fields }
func (*State) Descriptor
deprecated
added in
v0.2.1
func (*State) GetFailureRate ¶ added in v0.2.1
func (*State) GetInvokers ¶ added in v0.2.1
func (*State) GetInvokersRepresentation ¶ added in v0.2.1
func (*State) GetMeanExecutionsPerInstance ¶ added in v0.2.1
func (*State) GetMeanMillisecondsPerInstance ¶ added in v0.2.1
func (*State) GetMeanOutcomes ¶ added in v0.2.1
func (x *State) GetMeanOutcomes() *MeanOutcomes
func (*State) GetMeanRetries ¶ added in v0.2.1
func (*State) GetOutcomes ¶ added in v0.2.1
func (*State) GetSuccessRate ¶ added in v0.2.1
func (*State) GetTotalExecutions ¶ added in v0.2.1
func (*State) GetTotalFailures ¶ added in v0.2.1
func (*State) GetTotalMilliseconds ¶ added in v0.2.1
func (*State) GetTotalRetries ¶ added in v0.2.1
func (*State) GetTotalSuccesses ¶ added in v0.2.1
func (*State) GetUnhandledErrors ¶ added in v0.2.1
func (*State) GetUnhandledErrorsRepresentation ¶ added in v0.2.1
func (*State) ProtoMessage ¶ added in v0.2.1
func (*State) ProtoMessage()
func (*State) ProtoReflect ¶ added in v0.2.1
func (x *State) ProtoReflect() protoreflect.Message
type StoreSecretRequest ¶
type StoreSecretRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"` // contains filtered or unexported fields }
func (*StoreSecretRequest) Descriptor
deprecated
func (*StoreSecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreSecretRequest.ProtoReflect.Descriptor instead.
func (*StoreSecretRequest) GetData ¶
func (x *StoreSecretRequest) GetData() []byte
func (*StoreSecretRequest) GetName ¶
func (x *StoreSecretRequest) GetName() string
func (*StoreSecretRequest) GetNamespace ¶
func (x *StoreSecretRequest) GetNamespace() string
func (*StoreSecretRequest) ProtoMessage ¶
func (*StoreSecretRequest) ProtoMessage()
func (*StoreSecretRequest) ProtoReflect ¶
func (x *StoreSecretRequest) ProtoReflect() protoreflect.Message
func (*StoreSecretRequest) Reset ¶
func (x *StoreSecretRequest) Reset()
func (*StoreSecretRequest) String ¶
func (x *StoreSecretRequest) String() string
type UnimplementedDirektivIngressServer ¶
type UnimplementedDirektivIngressServer struct { }
UnimplementedDirektivIngressServer must be embedded to have forward compatible implementations.
func (UnimplementedDirektivIngressServer) AddNamespace ¶
func (UnimplementedDirektivIngressServer) AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error)
func (UnimplementedDirektivIngressServer) AddWorkflow ¶
func (UnimplementedDirektivIngressServer) AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) BroadcastEvent ¶
func (UnimplementedDirektivIngressServer) BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) CancelWorkflowInstance ¶
func (UnimplementedDirektivIngressServer) CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) DeleteNamespace ¶
func (UnimplementedDirektivIngressServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
func (UnimplementedDirektivIngressServer) DeleteSecret ¶
func (UnimplementedDirektivIngressServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) DeleteWorkflow ¶
func (UnimplementedDirektivIngressServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) GetInstancesByWorkflow ¶ added in v0.2.1
func (UnimplementedDirektivIngressServer) GetInstancesByWorkflow(context.Context, *GetInstancesByWorkflowRequest) (*GetInstancesByWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) GetNamespaceLogs ¶ added in v0.2.5
func (UnimplementedDirektivIngressServer) GetNamespaceLogs(context.Context, *GetNamespaceLogsRequest) (*GetNamespaceLogsResponse, error)
func (UnimplementedDirektivIngressServer) GetNamespaceVariable ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivIngress_GetNamespaceVariableServer) error
func (UnimplementedDirektivIngressServer) GetNamespaces ¶
func (UnimplementedDirektivIngressServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
func (UnimplementedDirektivIngressServer) GetSecrets ¶
func (UnimplementedDirektivIngressServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowByName ¶ added in v0.2.1
func (UnimplementedDirektivIngressServer) GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*GetWorkflowByNameResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowByUid ¶
func (UnimplementedDirektivIngressServer) GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowInstance ¶
func (UnimplementedDirektivIngressServer) GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowInstanceLogs ¶
func (UnimplementedDirektivIngressServer) GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowInstances ¶
func (UnimplementedDirektivIngressServer) GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowVariable ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivIngress_GetWorkflowVariableServer) error
func (UnimplementedDirektivIngressServer) GetWorkflows ¶
func (UnimplementedDirektivIngressServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
func (UnimplementedDirektivIngressServer) InvokeWorkflow ¶
func (UnimplementedDirektivIngressServer) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) ListNamespaceVariables ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) ListNamespaceVariables(context.Context, *ListNamespaceVariablesRequest) (*ListNamespaceVariablesResponse, error)
func (UnimplementedDirektivIngressServer) ListWorkflowVariables ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) ListWorkflowVariables(context.Context, *ListWorkflowVariablesRequest) (*ListWorkflowVariablesResponse, error)
func (UnimplementedDirektivIngressServer) SetNamespaceVariable ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) SetNamespaceVariable(DirektivIngress_SetNamespaceVariableServer) error
func (UnimplementedDirektivIngressServer) SetWorkflowVariable ¶ added in v0.2.3
func (UnimplementedDirektivIngressServer) SetWorkflowVariable(DirektivIngress_SetWorkflowVariableServer) error
func (UnimplementedDirektivIngressServer) StoreSecret ¶
func (UnimplementedDirektivIngressServer) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) UpdateWorkflow ¶
func (UnimplementedDirektivIngressServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) WatchWorkflowInstanceLogs ¶ added in v0.4.1
func (UnimplementedDirektivIngressServer) WatchWorkflowInstanceLogs(*WatchWorkflowInstanceLogsRequest, DirektivIngress_WatchWorkflowInstanceLogsServer) error
func (UnimplementedDirektivIngressServer) WorkflowMetrics ¶ added in v0.2.1
func (UnimplementedDirektivIngressServer) WorkflowMetrics(context.Context, *WorkflowMetricsRequest) (*WorkflowMetricsResponse, error)
type UnsafeDirektivIngressServer ¶
type UnsafeDirektivIngressServer interface {
// contains filtered or unexported methods
}
UnsafeDirektivIngressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DirektivIngressServer will result in compilation errors.
type UpdateWorkflowRequest ¶
type UpdateWorkflowRequest struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Revision *int32 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,3,opt,name=active,proto3,oneof" json:"active,omitempty"` Workflow []byte `protobuf:"bytes,4,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` LogToEvents *string `protobuf:"bytes,5,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"` // contains filtered or unexported fields }
func (*UpdateWorkflowRequest) Descriptor
deprecated
func (*UpdateWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateWorkflowRequest.ProtoReflect.Descriptor instead.
func (*UpdateWorkflowRequest) GetActive ¶
func (x *UpdateWorkflowRequest) GetActive() bool
func (*UpdateWorkflowRequest) GetLogToEvents ¶ added in v0.1.3
func (x *UpdateWorkflowRequest) GetLogToEvents() string
func (*UpdateWorkflowRequest) GetRevision ¶
func (x *UpdateWorkflowRequest) GetRevision() int32
func (*UpdateWorkflowRequest) GetUid ¶
func (x *UpdateWorkflowRequest) GetUid() string
func (*UpdateWorkflowRequest) GetWorkflow ¶
func (x *UpdateWorkflowRequest) GetWorkflow() []byte
func (*UpdateWorkflowRequest) ProtoMessage ¶
func (*UpdateWorkflowRequest) ProtoMessage()
func (*UpdateWorkflowRequest) ProtoReflect ¶
func (x *UpdateWorkflowRequest) ProtoReflect() protoreflect.Message
func (*UpdateWorkflowRequest) Reset ¶
func (x *UpdateWorkflowRequest) Reset()
func (*UpdateWorkflowRequest) String ¶
func (x *UpdateWorkflowRequest) String() string
type UpdateWorkflowResponse ¶
type UpdateWorkflowResponse struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"` Revision *int32 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"` Active *bool `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*UpdateWorkflowResponse) Descriptor
deprecated
func (*UpdateWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateWorkflowResponse.ProtoReflect.Descriptor instead.
func (*UpdateWorkflowResponse) GetActive ¶
func (x *UpdateWorkflowResponse) GetActive() bool
func (*UpdateWorkflowResponse) GetCreatedAt ¶
func (x *UpdateWorkflowResponse) GetCreatedAt() *timestamp.Timestamp
func (*UpdateWorkflowResponse) GetId ¶
func (x *UpdateWorkflowResponse) GetId() string
func (*UpdateWorkflowResponse) GetRevision ¶
func (x *UpdateWorkflowResponse) GetRevision() int32
func (*UpdateWorkflowResponse) GetUid ¶
func (x *UpdateWorkflowResponse) GetUid() string
func (*UpdateWorkflowResponse) ProtoMessage ¶
func (*UpdateWorkflowResponse) ProtoMessage()
func (*UpdateWorkflowResponse) ProtoReflect ¶
func (x *UpdateWorkflowResponse) ProtoReflect() protoreflect.Message
func (*UpdateWorkflowResponse) Reset ¶
func (x *UpdateWorkflowResponse) Reset()
func (*UpdateWorkflowResponse) String ¶
func (x *UpdateWorkflowResponse) String() string
type WatchWorkflowInstanceLogsRequest ¶ added in v0.4.1
type WatchWorkflowInstanceLogsRequest struct { InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"` // contains filtered or unexported fields }
func (*WatchWorkflowInstanceLogsRequest) Descriptor
deprecated
added in
v0.4.1
func (*WatchWorkflowInstanceLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchWorkflowInstanceLogsRequest.ProtoReflect.Descriptor instead.
func (*WatchWorkflowInstanceLogsRequest) GetInstanceId ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsRequest) GetInstanceId() string
func (*WatchWorkflowInstanceLogsRequest) ProtoMessage ¶ added in v0.4.1
func (*WatchWorkflowInstanceLogsRequest) ProtoMessage()
func (*WatchWorkflowInstanceLogsRequest) ProtoReflect ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsRequest) ProtoReflect() protoreflect.Message
func (*WatchWorkflowInstanceLogsRequest) Reset ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsRequest) Reset()
func (*WatchWorkflowInstanceLogsRequest) String ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsRequest) String() string
type WatchWorkflowInstanceLogsResponse ¶ added in v0.4.1
type WatchWorkflowInstanceLogsResponse struct { Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"` Level *string `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"` Message *string `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"` Context map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WatchWorkflowInstanceLogsResponse) Descriptor
deprecated
added in
v0.4.1
func (*WatchWorkflowInstanceLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchWorkflowInstanceLogsResponse.ProtoReflect.Descriptor instead.
func (*WatchWorkflowInstanceLogsResponse) GetContext ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) GetContext() map[string]string
func (*WatchWorkflowInstanceLogsResponse) GetId ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) GetId() string
func (*WatchWorkflowInstanceLogsResponse) GetLevel ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) GetLevel() string
func (*WatchWorkflowInstanceLogsResponse) GetMessage ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) GetMessage() string
func (*WatchWorkflowInstanceLogsResponse) GetTimestamp ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) GetTimestamp() *timestamp.Timestamp
func (*WatchWorkflowInstanceLogsResponse) ProtoMessage ¶ added in v0.4.1
func (*WatchWorkflowInstanceLogsResponse) ProtoMessage()
func (*WatchWorkflowInstanceLogsResponse) ProtoReflect ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) ProtoReflect() protoreflect.Message
func (*WatchWorkflowInstanceLogsResponse) Reset ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) Reset()
func (*WatchWorkflowInstanceLogsResponse) String ¶ added in v0.4.1
func (x *WatchWorkflowInstanceLogsResponse) String() string
type WorkflowMetricsRequest ¶ added in v0.2.1
type WorkflowMetricsRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Workflow *string `protobuf:"bytes,2,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"` SinceTimestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=sinceTimestamp,proto3,oneof" json:"sinceTimestamp,omitempty"` // contains filtered or unexported fields }
func (*WorkflowMetricsRequest) Descriptor
deprecated
added in
v0.2.1
func (*WorkflowMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMetricsRequest.ProtoReflect.Descriptor instead.
func (*WorkflowMetricsRequest) GetNamespace ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) GetNamespace() string
func (*WorkflowMetricsRequest) GetSinceTimestamp ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) GetSinceTimestamp() *timestamp.Timestamp
func (*WorkflowMetricsRequest) GetWorkflow ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) GetWorkflow() string
func (*WorkflowMetricsRequest) ProtoMessage ¶ added in v0.2.1
func (*WorkflowMetricsRequest) ProtoMessage()
func (*WorkflowMetricsRequest) ProtoReflect ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) ProtoReflect() protoreflect.Message
func (*WorkflowMetricsRequest) Reset ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) Reset()
func (*WorkflowMetricsRequest) String ¶ added in v0.2.1
func (x *WorkflowMetricsRequest) String() string
type WorkflowMetricsResponse ¶ added in v0.2.1
type WorkflowMetricsResponse struct { TotalInstancesRun *int32 `protobuf:"varint,1,opt,name=totalInstancesRun,proto3,oneof" json:"totalInstancesRun,omitempty"` TotalInstanceMilliseconds *int32 `protobuf:"varint,2,opt,name=totalInstanceMilliseconds,proto3,oneof" json:"totalInstanceMilliseconds,omitempty"` SuccessfulExecutions *int32 `protobuf:"varint,3,opt,name=successfulExecutions,proto3,oneof" json:"successfulExecutions,omitempty"` FailedExecutions *int32 `protobuf:"varint,4,opt,name=failedExecutions,proto3,oneof" json:"failedExecutions,omitempty"` ErrorCodes map[string]int32 `` /* 162-byte string literal not displayed */ ErrorCodesRepresentation map[string]float32 `` /* 191-byte string literal not displayed */ SampleSize *int32 `protobuf:"varint,7,opt,name=sampleSize,proto3,oneof" json:"sampleSize,omitempty"` MeanInstanceMilliseconds *int32 `protobuf:"varint,8,opt,name=meanInstanceMilliseconds,proto3,oneof" json:"meanInstanceMilliseconds,omitempty"` SuccessRate *float32 `protobuf:"fixed32,9,opt,name=successRate,proto3,oneof" json:"successRate,omitempty"` FailureRate *float32 `protobuf:"fixed32,10,opt,name=failureRate,proto3,oneof" json:"failureRate,omitempty"` States []*State `protobuf:"bytes,11,rep,name=states,proto3" json:"states,omitempty"` // contains filtered or unexported fields }
func (*WorkflowMetricsResponse) Descriptor
deprecated
added in
v0.2.1
func (*WorkflowMetricsResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMetricsResponse.ProtoReflect.Descriptor instead.
func (*WorkflowMetricsResponse) GetErrorCodes ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetErrorCodes() map[string]int32
func (*WorkflowMetricsResponse) GetErrorCodesRepresentation ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetErrorCodesRepresentation() map[string]float32
func (*WorkflowMetricsResponse) GetFailedExecutions ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetFailedExecutions() int32
func (*WorkflowMetricsResponse) GetFailureRate ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetFailureRate() float32
func (*WorkflowMetricsResponse) GetMeanInstanceMilliseconds ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetMeanInstanceMilliseconds() int32
func (*WorkflowMetricsResponse) GetSampleSize ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetSampleSize() int32
func (*WorkflowMetricsResponse) GetStates ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetStates() []*State
func (*WorkflowMetricsResponse) GetSuccessRate ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetSuccessRate() float32
func (*WorkflowMetricsResponse) GetSuccessfulExecutions ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetSuccessfulExecutions() int32
func (*WorkflowMetricsResponse) GetTotalInstanceMilliseconds ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetTotalInstanceMilliseconds() int32
func (*WorkflowMetricsResponse) GetTotalInstancesRun ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) GetTotalInstancesRun() int32
func (*WorkflowMetricsResponse) ProtoMessage ¶ added in v0.2.1
func (*WorkflowMetricsResponse) ProtoMessage()
func (*WorkflowMetricsResponse) ProtoReflect ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) ProtoReflect() protoreflect.Message
func (*WorkflowMetricsResponse) Reset ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) Reset()
func (*WorkflowMetricsResponse) String ¶ added in v0.2.1
func (x *WorkflowMetricsResponse) String() string
Source Files ¶
- add-namespace.pb.go
- add-workflow.pb.go
- broadcast-event.pb.go
- cancel-instance.pb.go
- delete-namespace.pb.go
- delete-secret.pb.go
- delete-workflow.pb.go
- get-instance-logs.pb.go
- get-instance.pb.go
- get-instances-by-workflow.pb.go
- get-instances.pb.go
- get-namespace-logs.pb.go
- get-namespace-variable.pb.go
- get-namespaces.pb.go
- get-secrets.pb.go
- get-workflow-name.pb.go
- get-workflow-uid.pb.go
- get-workflow-variable.pb.go
- get-workflows.pb.go
- invoke.pb.go
- list-namespace-variables.pb.go
- list-workflow-variables.pb.go
- protocol.pb.go
- protocol_grpc.pb.go
- set-namespace-variable.pb.go
- set-workflow-variable.pb.go
- store-secret.pb.go
- update-workflow.pb.go
- watch-instance-logs.pb.go
- workflow-metrics.pb.go