ingress

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: May 27, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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: "GetRegistries",
			Handler:    _DirektivIngress_GetRegistries_Handler,
		},
		{
			MethodName: "DeleteRegistry",
			Handler:    _DirektivIngress_DeleteRegistry_Handler,
		},
		{
			MethodName: "StoreRegistry",
			Handler:    _DirektivIngress_StoreRegistry_Handler,
		},
		{
			MethodName: "WorkflowMetrics",
			Handler:    _DirektivIngress_WorkflowMetrics_Handler,
		},
		{
			MethodName: "ListNamespaceVariables",
			Handler:    _DirektivIngress_ListNamespaceVariables_Handler,
		},
		{
			MethodName: "ListWorkflowVariables",
			Handler:    _DirektivIngress_ListWorkflowVariables_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			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)

View Source 
var File_pkg_ingress_add_namespace_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_add_workflow_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_broadcast_event_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_cancel_instance_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_delete_namespace_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_delete_registry_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_delete_secret_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_delete_workflow_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_instance_logs_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_instance_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_instances_by_workflow_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_instances_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_namespace_logs_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_namespace_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_namespaces_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_registries_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_secrets_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_workflow_name_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_workflow_uid_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_workflow_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_workflows_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_invoke_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_list_namespace_variables_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_list_workflow_variables_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_protocol_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_set_namespace_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_set_workflow_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_store_registry_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_store_secret_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_update_workflow_proto protoreflect.FileDescriptor
View Source 
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"`
	// 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)
	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)
	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)
	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)
	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)
	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 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 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"`
	Id   *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,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) GetId added in v0.2.1 

func (x *GetRegistriesResponse_Registry) GetId() string

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 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"`
	// 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) 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"`
	// 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) 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 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"`
	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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use Outcomes.ProtoReflect.Descriptor instead.

func (*Outcomes) GetFailure added in v0.2.1 

func (x *Outcomes) GetFailure() int32

func (*Outcomes) GetSuccess added in v0.2.1 

func (x *Outcomes) GetSuccess() int32

func (*Outcomes) GetTransitions added in v0.2.1 

func (x *Outcomes) GetTransitions() map[string]int32

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

func (*Outcomes) Reset added in v0.2.1 

func (x *Outcomes) Reset()

func (*Outcomes) String added in v0.2.1 

func (x *Outcomes) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetFailureRate added in v0.2.1 

func (x *State) GetFailureRate() float32

func (*State) GetInvokers added in v0.2.1 

func (x *State) GetInvokers() map[string]int32

func (*State) GetInvokersRepresentation added in v0.2.1 

func (x *State) GetInvokersRepresentation() map[string]float32

func (*State) GetMeanExecutionsPerInstance added in v0.2.1 

func (x *State) GetMeanExecutionsPerInstance() int32

func (*State) GetMeanMillisecondsPerInstance added in v0.2.1 

func (x *State) GetMeanMillisecondsPerInstance() int32

func (*State) GetMeanOutcomes added in v0.2.1 

func (x *State) GetMeanOutcomes() *MeanOutcomes

func (*State) GetMeanRetries added in v0.2.1 

func (x *State) GetMeanRetries() float32

func (*State) GetName added in v0.2.1 

func (x *State) GetName() string

func (*State) GetOutcomes added in v0.2.1 

func (x *State) GetOutcomes() *Outcomes

func (*State) GetSuccessRate added in v0.2.1 

func (x *State) GetSuccessRate() float32

func (*State) GetTotalExecutions added in v0.2.1 

func (x *State) GetTotalExecutions() int32

func (*State) GetTotalFailures added in v0.2.1 

func (x *State) GetTotalFailures() int32

func (*State) GetTotalMilliseconds added in v0.2.1 

func (x *State) GetTotalMilliseconds() int32

func (*State) GetTotalRetries added in v0.2.1 

func (x *State) GetTotalRetries() int32

func (*State) GetTotalSuccesses added in v0.2.1 

func (x *State) GetTotalSuccesses() int32

func (*State) GetUnhandledErrors added in v0.2.1 

func (x *State) GetUnhandledErrors() map[string]int32

func (*State) GetUnhandledErrorsRepresentation added in v0.2.1 

func (x *State) GetUnhandledErrorsRepresentation() map[string]float32

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

func (*State) Reset added in v0.2.1 

func (x *State) Reset()

func (*State) String added in v0.2.1 

func (x *State) 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) 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) GetRegistries 

func (UnimplementedDirektivIngressServer) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, 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) 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)

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

View all Source files

Jump to

Keyboard shortcuts

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