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 (*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 DeleteRegistryRequest
- func (*DeleteRegistryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRegistryRequest) GetName() string
- func (x *DeleteRegistryRequest) GetNamespace() string
- func (*DeleteRegistryRequest) ProtoMessage()
- func (x *DeleteRegistryRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRegistryRequest) Reset()
- func (x *DeleteRegistryRequest) 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 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 GetRegistriesRequest
- func (*GetRegistriesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRegistriesRequest) GetNamespace() string
- func (*GetRegistriesRequest) ProtoMessage()
- func (x *GetRegistriesRequest) ProtoReflect() protoreflect.Message
- func (x *GetRegistriesRequest) Reset()
- func (x *GetRegistriesRequest) String() string
- type GetRegistriesResponse
- func (*GetRegistriesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRegistriesResponse) GetRegistries() []*GetRegistriesResponse_Registry
- func (*GetRegistriesResponse) ProtoMessage()
- func (x *GetRegistriesResponse) ProtoReflect() protoreflect.Message
- func (x *GetRegistriesResponse) Reset()
- func (x *GetRegistriesResponse) String() string
- type GetRegistriesResponse_Registry
- func (*GetRegistriesResponse_Registry) Descriptor() ([]byte, []int)deprecated
- func (x *GetRegistriesResponse_Registry) GetName() string
- func (*GetRegistriesResponse_Registry) ProtoMessage()
- func (x *GetRegistriesResponse_Registry) ProtoReflect() protoreflect.Message
- func (x *GetRegistriesResponse_Registry) Reset()
- func (x *GetRegistriesResponse_Registry) 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 GetWorkflowByIdRequest
- func (*GetWorkflowByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByIdRequest) GetId() string
- func (x *GetWorkflowByIdRequest) GetNamespace() string
- func (*GetWorkflowByIdRequest) ProtoMessage()
- func (x *GetWorkflowByIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByIdRequest) Reset()
- func (x *GetWorkflowByIdRequest) String() string
- type GetWorkflowByIdResponse
- func (*GetWorkflowByIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowByIdResponse) GetActive() bool
- func (x *GetWorkflowByIdResponse) GetCreatedAt() *timestamp.Timestamp
- func (x *GetWorkflowByIdResponse) GetDescription() string
- func (x *GetWorkflowByIdResponse) GetId() string
- func (x *GetWorkflowByIdResponse) GetLogToEvents() string
- func (x *GetWorkflowByIdResponse) GetRevision() int32
- func (x *GetWorkflowByIdResponse) GetUid() string
- func (x *GetWorkflowByIdResponse) GetWorkflow() []byte
- func (*GetWorkflowByIdResponse) ProtoMessage()
- func (x *GetWorkflowByIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowByIdResponse) Reset()
- func (x *GetWorkflowByIdResponse) String() string
- type GetWorkflowByUidRequest
- func (*GetWorkflowByUidRequest) Descriptor() ([]byte, []int)deprecated
- 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) 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 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) 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 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) GetNamespace() string
- func (x *InvokeWorkflowRequest) GetWorkflowId() string
- 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) GetInstanceId() string
- func (*InvokeWorkflowResponse) ProtoMessage()
- func (x *InvokeWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *InvokeWorkflowResponse) Reset()
- func (x *InvokeWorkflowResponse) String() string
- type StoreRegistryRequest
- func (*StoreRegistryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreRegistryRequest) GetData() []byte
- func (x *StoreRegistryRequest) GetName() string
- func (x *StoreRegistryRequest) GetNamespace() string
- func (*StoreRegistryRequest) ProtoMessage()
- func (x *StoreRegistryRequest) ProtoReflect() protoreflect.Message
- func (x *StoreRegistryRequest) Reset()
- func (x *StoreRegistryRequest) 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) DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
- func (UnimplementedDirektivIngressServer) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)
- func (UnimplementedDirektivIngressServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
- func (UnimplementedDirektivIngressServer) GetWorkflowById(context.Context, *GetWorkflowByIdRequest) (*GetWorkflowByIdResponse, 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) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
- func (UnimplementedDirektivIngressServer) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
- func (UnimplementedDirektivIngressServer) StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
- func (UnimplementedDirektivIngressServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, 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
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: "GetWorkflowById", Handler: _DirektivIngress_GetWorkflowById_Handler, }, { MethodName: "GetWorkflowByUid", Handler: _DirektivIngress_GetWorkflowByUid_Handler, }, { MethodName: "GetWorkflowInstance", Handler: _DirektivIngress_GetWorkflowInstance_Handler, }, { MethodName: "GetWorkflowInstances", Handler: _DirektivIngress_GetWorkflowInstances_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: "GetRegistries", Handler: _DirektivIngress_GetRegistries_Handler, }, { MethodName: "DeleteRegistry", Handler: _DirektivIngress_DeleteRegistry_Handler, }, { MethodName: "StoreRegistry", Handler: _DirektivIngress_StoreRegistry_Handler, }, }, Streams: []grpc.StreamDesc{}, 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_registry_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_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_namespaces_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_registries_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_secrets_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflow_id_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflow_uid_proto protoreflect.FileDescriptor
var File_pkg_ingress_get_workflows_proto protoreflect.FileDescriptor
var File_pkg_ingress_invoke_proto protoreflect.FileDescriptor
var File_pkg_ingress_protocol_proto protoreflect.FileDescriptor
var File_pkg_ingress_store_registry_proto protoreflect.FileDescriptor
var File_pkg_ingress_store_secret_proto protoreflect.FileDescriptor
var File_pkg_ingress_update_workflow_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"` // 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) 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 DeleteRegistryRequest ¶
type DeleteRegistryRequest 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 (*DeleteRegistryRequest) Descriptor
deprecated
func (*DeleteRegistryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRegistryRequest.ProtoReflect.Descriptor instead.
func (*DeleteRegistryRequest) GetName ¶
func (x *DeleteRegistryRequest) GetName() string
func (*DeleteRegistryRequest) GetNamespace ¶
func (x *DeleteRegistryRequest) GetNamespace() string
func (*DeleteRegistryRequest) ProtoMessage ¶
func (*DeleteRegistryRequest) ProtoMessage()
func (*DeleteRegistryRequest) ProtoReflect ¶
func (x *DeleteRegistryRequest) ProtoReflect() protoreflect.Message
func (*DeleteRegistryRequest) Reset ¶
func (x *DeleteRegistryRequest) Reset()
func (*DeleteRegistryRequest) String ¶
func (x *DeleteRegistryRequest) 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) GetWorkflowById(ctx context.Context, in *GetWorkflowByIdRequest, opts ...grpc.CallOption) (*GetWorkflowByIdResponse, 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) GetWorkflowInstanceLogs(ctx context.Context, in *GetWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceLogsResponse, 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) GetRegistries(ctx context.Context, in *GetRegistriesRequest, opts ...grpc.CallOption) (*GetRegistriesResponse, error) DeleteRegistry(ctx context.Context, in *DeleteRegistryRequest, opts ...grpc.CallOption) (*empty.Empty, error) StoreRegistry(ctx context.Context, in *StoreRegistryRequest, opts ...grpc.CallOption) (*empty.Empty, 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) GetWorkflowById(context.Context, *GetWorkflowByIdRequest) (*GetWorkflowByIdResponse, error) GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error) GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error) GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error) GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, 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) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error) DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, error) StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error) // contains filtered or unexported methods }
DirektivIngressServer is the server API for DirektivIngress service. All implementations must embed UnimplementedDirektivIngressServer for forward compatibility
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 GetRegistriesRequest ¶
type GetRegistriesRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*GetRegistriesRequest) Descriptor
deprecated
func (*GetRegistriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRegistriesRequest.ProtoReflect.Descriptor instead.
func (*GetRegistriesRequest) GetNamespace ¶
func (x *GetRegistriesRequest) GetNamespace() string
func (*GetRegistriesRequest) ProtoMessage ¶
func (*GetRegistriesRequest) ProtoMessage()
func (*GetRegistriesRequest) ProtoReflect ¶
func (x *GetRegistriesRequest) ProtoReflect() protoreflect.Message
func (*GetRegistriesRequest) Reset ¶
func (x *GetRegistriesRequest) Reset()
func (*GetRegistriesRequest) String ¶
func (x *GetRegistriesRequest) String() string
type GetRegistriesResponse ¶
type GetRegistriesResponse struct { Registries []*GetRegistriesResponse_Registry `protobuf:"bytes,1,rep,name=registries,proto3" json:"registries,omitempty"` // contains filtered or unexported fields }
func (*GetRegistriesResponse) Descriptor
deprecated
func (*GetRegistriesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRegistriesResponse.ProtoReflect.Descriptor instead.
func (*GetRegistriesResponse) GetRegistries ¶
func (x *GetRegistriesResponse) GetRegistries() []*GetRegistriesResponse_Registry
func (*GetRegistriesResponse) ProtoMessage ¶
func (*GetRegistriesResponse) ProtoMessage()
func (*GetRegistriesResponse) ProtoReflect ¶
func (x *GetRegistriesResponse) ProtoReflect() protoreflect.Message
func (*GetRegistriesResponse) Reset ¶
func (x *GetRegistriesResponse) Reset()
func (*GetRegistriesResponse) String ¶
func (x *GetRegistriesResponse) String() string
type GetRegistriesResponse_Registry ¶
type GetRegistriesResponse_Registry struct { Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetRegistriesResponse_Registry) Descriptor
deprecated
func (*GetRegistriesResponse_Registry) Descriptor() ([]byte, []int)
Deprecated: Use GetRegistriesResponse_Registry.ProtoReflect.Descriptor instead.
func (*GetRegistriesResponse_Registry) GetName ¶
func (x *GetRegistriesResponse_Registry) GetName() string
func (*GetRegistriesResponse_Registry) ProtoMessage ¶
func (*GetRegistriesResponse_Registry) ProtoMessage()
func (*GetRegistriesResponse_Registry) ProtoReflect ¶
func (x *GetRegistriesResponse_Registry) ProtoReflect() protoreflect.Message
func (*GetRegistriesResponse_Registry) Reset ¶
func (x *GetRegistriesResponse_Registry) Reset()
func (*GetRegistriesResponse_Registry) String ¶
func (x *GetRegistriesResponse_Registry) 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 GetWorkflowByIdRequest ¶
type GetWorkflowByIdRequest struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Id *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByIdRequest) Descriptor
deprecated
func (*GetWorkflowByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByIdRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowByIdRequest) GetId ¶
func (x *GetWorkflowByIdRequest) GetId() string
func (*GetWorkflowByIdRequest) GetNamespace ¶
func (x *GetWorkflowByIdRequest) GetNamespace() string
func (*GetWorkflowByIdRequest) ProtoMessage ¶
func (*GetWorkflowByIdRequest) ProtoMessage()
func (*GetWorkflowByIdRequest) ProtoReflect ¶
func (x *GetWorkflowByIdRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowByIdRequest) Reset ¶
func (x *GetWorkflowByIdRequest) Reset()
func (*GetWorkflowByIdRequest) String ¶
func (x *GetWorkflowByIdRequest) String() string
type GetWorkflowByIdResponse ¶
type GetWorkflowByIdResponse 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"` // contains filtered or unexported fields }
func (*GetWorkflowByIdResponse) Descriptor
deprecated
func (*GetWorkflowByIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByIdResponse.ProtoReflect.Descriptor instead.
func (*GetWorkflowByIdResponse) GetActive ¶
func (x *GetWorkflowByIdResponse) GetActive() bool
func (*GetWorkflowByIdResponse) GetCreatedAt ¶
func (x *GetWorkflowByIdResponse) GetCreatedAt() *timestamp.Timestamp
func (*GetWorkflowByIdResponse) GetDescription ¶
func (x *GetWorkflowByIdResponse) GetDescription() string
func (*GetWorkflowByIdResponse) GetId ¶
func (x *GetWorkflowByIdResponse) GetId() string
func (*GetWorkflowByIdResponse) GetLogToEvents ¶ added in v0.1.3
func (x *GetWorkflowByIdResponse) GetLogToEvents() string
func (*GetWorkflowByIdResponse) GetRevision ¶
func (x *GetWorkflowByIdResponse) GetRevision() int32
func (*GetWorkflowByIdResponse) GetUid ¶
func (x *GetWorkflowByIdResponse) GetUid() string
func (*GetWorkflowByIdResponse) GetWorkflow ¶
func (x *GetWorkflowByIdResponse) GetWorkflow() []byte
func (*GetWorkflowByIdResponse) ProtoMessage ¶
func (*GetWorkflowByIdResponse) ProtoMessage()
func (*GetWorkflowByIdResponse) ProtoReflect ¶
func (x *GetWorkflowByIdResponse) ProtoReflect() protoreflect.Message
func (*GetWorkflowByIdResponse) Reset ¶
func (x *GetWorkflowByIdResponse) Reset()
func (*GetWorkflowByIdResponse) String ¶
func (x *GetWorkflowByIdResponse) String() string
type GetWorkflowByUidRequest ¶
type GetWorkflowByUidRequest struct { Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowByUidRequest) Descriptor
deprecated
func (*GetWorkflowByUidRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowByUidRequest.ProtoReflect.Descriptor instead.
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"` // 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) 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 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"` // 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) 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 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"` WorkflowId *string `protobuf:"bytes,2,opt,name=workflowId,proto3,oneof" json:"workflowId,omitempty"` Input []byte `protobuf:"bytes,3,opt,name=input,proto3,oneof" json:"input,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) GetNamespace ¶
func (x *InvokeWorkflowRequest) GetNamespace() string
func (*InvokeWorkflowRequest) GetWorkflowId ¶
func (x *InvokeWorkflowRequest) GetWorkflowId() string
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"` // contains filtered or unexported fields }
func (*InvokeWorkflowResponse) Descriptor
deprecated
func (*InvokeWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use InvokeWorkflowResponse.ProtoReflect.Descriptor instead.
func (*InvokeWorkflowResponse) GetInstanceId ¶
func (x *InvokeWorkflowResponse) GetInstanceId() string
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 StoreRegistryRequest ¶
type StoreRegistryRequest 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 (*StoreRegistryRequest) Descriptor
deprecated
func (*StoreRegistryRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreRegistryRequest.ProtoReflect.Descriptor instead.
func (*StoreRegistryRequest) GetData ¶
func (x *StoreRegistryRequest) GetData() []byte
func (*StoreRegistryRequest) GetName ¶
func (x *StoreRegistryRequest) GetName() string
func (*StoreRegistryRequest) GetNamespace ¶
func (x *StoreRegistryRequest) GetNamespace() string
func (*StoreRegistryRequest) ProtoMessage ¶
func (*StoreRegistryRequest) ProtoMessage()
func (*StoreRegistryRequest) ProtoReflect ¶
func (x *StoreRegistryRequest) ProtoReflect() protoreflect.Message
func (*StoreRegistryRequest) Reset ¶
func (x *StoreRegistryRequest) Reset()
func (*StoreRegistryRequest) String ¶
func (x *StoreRegistryRequest) String() string
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) DeleteRegistry ¶
func (UnimplementedDirektivIngressServer) DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, 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) GetNamespaces ¶
func (UnimplementedDirektivIngressServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
func (UnimplementedDirektivIngressServer) GetRegistries ¶
func (UnimplementedDirektivIngressServer) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)
func (UnimplementedDirektivIngressServer) GetSecrets ¶
func (UnimplementedDirektivIngressServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
func (UnimplementedDirektivIngressServer) GetWorkflowById ¶
func (UnimplementedDirektivIngressServer) GetWorkflowById(context.Context, *GetWorkflowByIdRequest) (*GetWorkflowByIdResponse, 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) GetWorkflows ¶
func (UnimplementedDirektivIngressServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
func (UnimplementedDirektivIngressServer) InvokeWorkflow ¶
func (UnimplementedDirektivIngressServer) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
func (UnimplementedDirektivIngressServer) StoreRegistry ¶
func (UnimplementedDirektivIngressServer) StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) StoreSecret ¶
func (UnimplementedDirektivIngressServer) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
func (UnimplementedDirektivIngressServer) UpdateWorkflow ¶
func (UnimplementedDirektivIngressServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, 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
Source Files ¶
- add-namespace.pb.go
- add-workflow.pb.go
- broadcast-event.pb.go
- cancel-instance.pb.go
- delete-namespace.pb.go
- delete-registry.pb.go
- delete-secret.pb.go
- delete-workflow.pb.go
- get-instance-logs.pb.go
- get-instance.pb.go
- get-instances.pb.go
- get-namespaces.pb.go
- get-registries.pb.go
- get-secrets.pb.go
- get-workflow-id.pb.go
- get-workflow-uid.pb.go
- get-workflows.pb.go
- invoke.pb.go
- protocol.pb.go
- protocol_grpc.pb.go
- store-registry.pb.go
- store-secret.pb.go
- update-workflow.pb.go