ingress

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 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: "GetWorkflowById",
			Handler:    _DirektivIngress_GetWorkflowById_Handler,
		},
		{
			MethodName: "GetWorkflowByUid",
			Handler:    _DirektivIngress_GetWorkflowByUid_Handler,
		},
		{
			MethodName: "GetWorkflowInstance",
			Handler:    _DirektivIngress_GetWorkflowInstance_Handler,
		},
		{
			MethodName: "GetWorkflowInstances",
			Handler:    _DirektivIngress_GetWorkflowInstances_Handler,
		},
		{
			MethodName: "GetWorkflowInstanceLogs",
			Handler:    _DirektivIngress_GetWorkflowInstanceLogs_Handler,
		},
		{
			MethodName: "CancelWorkflowInstance",
			Handler:    _DirektivIngress_CancelWorkflowInstance_Handler,
		},
		{
			MethodName: "GetWorkflows",
			Handler:    _DirektivIngress_GetWorkflows_Handler,
		},
		{
			MethodName: "InvokeWorkflow",
			Handler:    _DirektivIngress_InvokeWorkflow_Handler,
		},
		{
			MethodName: "UpdateWorkflow",
			Handler:    _DirektivIngress_UpdateWorkflow_Handler,
		},
		{
			MethodName: "BroadcastEvent",
			Handler:    _DirektivIngress_BroadcastEvent_Handler,
		},
		{
			MethodName: "GetSecrets",
			Handler:    _DirektivIngress_GetSecrets_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _DirektivIngress_DeleteSecret_Handler,
		},
		{
			MethodName: "StoreSecret",
			Handler:    _DirektivIngress_StoreSecret_Handler,
		},
		{
			MethodName: "GetRegistries",
			Handler:    _DirektivIngress_GetRegistries_Handler,
		},
		{
			MethodName: "DeleteRegistry",
			Handler:    _DirektivIngress_DeleteRegistry_Handler,
		},
		{
			MethodName: "StoreRegistry",
			Handler:    _DirektivIngress_StoreRegistry_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/ingress/protocol.proto",
}

DirektivIngress_ServiceDesc is the grpc.ServiceDesc for DirektivIngress service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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_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_id_proto protoreflect.FileDescriptor
View Source 
var File_pkg_ingress_get_workflow_uid_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_protocol_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

Functions

func RegisterDirektivIngressServer 

func RegisterDirektivIngressServer(s grpc.ServiceRegistrar, srv DirektivIngressServer)

Types

type AddNamespaceRequest 

type AddNamespaceRequest struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use AddNamespaceRequest.ProtoReflect.Descriptor instead.

func (*AddNamespaceRequest) GetName 

func (x *AddNamespaceRequest) GetName() string

func (*AddNamespaceRequest) ProtoMessage 

func (*AddNamespaceRequest) ProtoMessage()

func (*AddNamespaceRequest) ProtoReflect 

func (x *AddNamespaceRequest) ProtoReflect() protoreflect.Message

func (*AddNamespaceRequest) Reset 

func (x *AddNamespaceRequest) Reset()

func (*AddNamespaceRequest) String 

func (x *AddNamespaceRequest) String() string

type AddNamespaceResponse 

type AddNamespaceResponse struct {
	Name      *string              `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use AddNamespaceResponse.ProtoReflect.Descriptor instead.

func (*AddNamespaceResponse) GetCreatedAt 

func (x *AddNamespaceResponse) GetCreatedAt() *timestamp.Timestamp

func (*AddNamespaceResponse) GetName 

func (x *AddNamespaceResponse) GetName() string

func (*AddNamespaceResponse) ProtoMessage 

func (*AddNamespaceResponse) ProtoMessage()

func (*AddNamespaceResponse) ProtoReflect 

func (x *AddNamespaceResponse) ProtoReflect() protoreflect.Message

func (*AddNamespaceResponse) Reset 

func (x *AddNamespaceResponse) Reset()

func (*AddNamespaceResponse) String 

func (x *AddNamespaceResponse) String() string

type AddWorkflowRequest 

type AddWorkflowRequest struct {
	Namespace   *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Active      *bool   `protobuf:"varint,2,opt,name=active,proto3,oneof" json:"active,omitempty"`
	Workflow    []byte  `protobuf:"bytes,3,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	LogToEvents *string `protobuf:"bytes,4,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use AddWorkflowRequest.ProtoReflect.Descriptor instead.

func (*AddWorkflowRequest) GetActive 

func (x *AddWorkflowRequest) GetActive() bool

func (*AddWorkflowRequest) GetLogToEvents added in v0.1.3 

func (x *AddWorkflowRequest) GetLogToEvents() string

func (*AddWorkflowRequest) GetNamespace 

func (x *AddWorkflowRequest) GetNamespace() string

func (*AddWorkflowRequest) GetWorkflow 

func (x *AddWorkflowRequest) GetWorkflow() []byte

func (*AddWorkflowRequest) ProtoMessage 

func (*AddWorkflowRequest) ProtoMessage()

func (*AddWorkflowRequest) ProtoReflect 

func (x *AddWorkflowRequest) ProtoReflect() protoreflect.Message

func (*AddWorkflowRequest) Reset 

func (x *AddWorkflowRequest) Reset()

func (*AddWorkflowRequest) String 

func (x *AddWorkflowRequest) String() string

type AddWorkflowResponse 

type AddWorkflowResponse struct {
	Uid       *string              `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Id        *string              `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Revision  *int32               `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active    *bool                `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use AddWorkflowResponse.ProtoReflect.Descriptor instead.

func (*AddWorkflowResponse) GetActive 

func (x *AddWorkflowResponse) GetActive() bool

func (*AddWorkflowResponse) GetCreatedAt 

func (x *AddWorkflowResponse) GetCreatedAt() *timestamp.Timestamp

func (*AddWorkflowResponse) GetId 

func (x *AddWorkflowResponse) GetId() string

func (*AddWorkflowResponse) GetRevision 

func (x *AddWorkflowResponse) GetRevision() int32

func (*AddWorkflowResponse) GetUid 

func (x *AddWorkflowResponse) GetUid() string

func (*AddWorkflowResponse) ProtoMessage 

func (*AddWorkflowResponse) ProtoMessage()

func (*AddWorkflowResponse) ProtoReflect 

func (x *AddWorkflowResponse) ProtoReflect() protoreflect.Message

func (*AddWorkflowResponse) Reset 

func (x *AddWorkflowResponse) Reset()

func (*AddWorkflowResponse) String 

func (x *AddWorkflowResponse) String() string

type BroadcastEventRequest 

type BroadcastEventRequest struct {
	Namespace  *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Cloudevent []byte  `protobuf:"bytes,2,opt,name=cloudevent,proto3,oneof" json:"cloudevent,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastEventRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastEventRequest.ProtoReflect.Descriptor instead.

func (*BroadcastEventRequest) GetCloudevent 

func (x *BroadcastEventRequest) GetCloudevent() []byte

func (*BroadcastEventRequest) GetNamespace 

func (x *BroadcastEventRequest) GetNamespace() string

func (*BroadcastEventRequest) ProtoMessage 

func (*BroadcastEventRequest) ProtoMessage()

func (*BroadcastEventRequest) ProtoReflect 

func (x *BroadcastEventRequest) ProtoReflect() protoreflect.Message

func (*BroadcastEventRequest) Reset 

func (x *BroadcastEventRequest) Reset()

func (*BroadcastEventRequest) String 

func (x *BroadcastEventRequest) String() string

type CancelWorkflowInstanceRequest 

type CancelWorkflowInstanceRequest struct {
	Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelWorkflowInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowInstanceRequest) GetId 

func (x *CancelWorkflowInstanceRequest) GetId() string

func (*CancelWorkflowInstanceRequest) ProtoMessage 

func (*CancelWorkflowInstanceRequest) ProtoMessage()

func (*CancelWorkflowInstanceRequest) ProtoReflect 

func (x *CancelWorkflowInstanceRequest) ProtoReflect() protoreflect.Message

func (*CancelWorkflowInstanceRequest) Reset 

func (x *CancelWorkflowInstanceRequest) Reset()

func (*CancelWorkflowInstanceRequest) String 

func (x *CancelWorkflowInstanceRequest) String() string

type DeleteNamespaceRequest 

type DeleteNamespaceRequest struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetName 

func (x *DeleteNamespaceRequest) GetName() string

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect 

func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message

func (*DeleteNamespaceRequest) Reset 

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String 

func (x *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse 

type DeleteNamespaceResponse struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) GetName 

func (x *DeleteNamespaceResponse) GetName() string

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect 

func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message

func (*DeleteNamespaceResponse) Reset 

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String 

func (x *DeleteNamespaceResponse) String() string

type DeleteRegistryRequest 

type DeleteRegistryRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRegistryRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRegistryRequest.ProtoReflect.Descriptor instead.

func (*DeleteRegistryRequest) GetName 

func (x *DeleteRegistryRequest) GetName() string

func (*DeleteRegistryRequest) GetNamespace 

func (x *DeleteRegistryRequest) GetNamespace() string

func (*DeleteRegistryRequest) ProtoMessage 

func (*DeleteRegistryRequest) ProtoMessage()

func (*DeleteRegistryRequest) ProtoReflect 

func (x *DeleteRegistryRequest) ProtoReflect() protoreflect.Message

func (*DeleteRegistryRequest) Reset 

func (x *DeleteRegistryRequest) Reset()

func (*DeleteRegistryRequest) String 

func (x *DeleteRegistryRequest) String() string

type DeleteSecretRequest 

type DeleteSecretRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSecretRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetName 

func (x *DeleteSecretRequest) GetName() string

func (*DeleteSecretRequest) GetNamespace 

func (x *DeleteSecretRequest) GetNamespace() string

func (*DeleteSecretRequest) ProtoMessage 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect 

func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message

func (*DeleteSecretRequest) Reset 

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String 

func (x *DeleteSecretRequest) String() string

type DeleteWorkflowRequest 

type DeleteWorkflowRequest struct {
	Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowRequest) GetUid 

func (x *DeleteWorkflowRequest) GetUid() string

func (*DeleteWorkflowRequest) ProtoMessage 

func (*DeleteWorkflowRequest) ProtoMessage()

func (*DeleteWorkflowRequest) ProtoReflect 

func (x *DeleteWorkflowRequest) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowRequest) Reset 

func (x *DeleteWorkflowRequest) Reset()

func (*DeleteWorkflowRequest) String 

func (x *DeleteWorkflowRequest) String() string

type DeleteWorkflowResponse 

type DeleteWorkflowResponse struct {
	Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowResponse) GetUid 

func (x *DeleteWorkflowResponse) GetUid() string

func (*DeleteWorkflowResponse) ProtoMessage 

func (*DeleteWorkflowResponse) ProtoMessage()

func (*DeleteWorkflowResponse) ProtoReflect 

func (x *DeleteWorkflowResponse) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowResponse) Reset 

func (x *DeleteWorkflowResponse) Reset()

func (*DeleteWorkflowResponse) String 

func (x *DeleteWorkflowResponse) String() string

type DirektivIngressClient 

type DirektivIngressClient interface {
	AddNamespace(ctx context.Context, in *AddNamespaceRequest, opts ...grpc.CallOption) (*AddNamespaceResponse, error)
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
	GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, error)
	AddWorkflow(ctx context.Context, in *AddWorkflowRequest, opts ...grpc.CallOption) (*AddWorkflowResponse, error)
	DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*DeleteWorkflowResponse, error)
	GetWorkflowById(ctx context.Context, in *GetWorkflowByIdRequest, opts ...grpc.CallOption) (*GetWorkflowByIdResponse, error)
	GetWorkflowByUid(ctx context.Context, in *GetWorkflowByUidRequest, opts ...grpc.CallOption) (*GetWorkflowByUidResponse, error)
	GetWorkflowInstance(ctx context.Context, in *GetWorkflowInstanceRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceResponse, error)
	GetWorkflowInstances(ctx context.Context, in *GetWorkflowInstancesRequest, opts ...grpc.CallOption) (*GetWorkflowInstancesResponse, error)
	GetWorkflowInstanceLogs(ctx context.Context, in *GetWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceLogsResponse, error)
	CancelWorkflowInstance(ctx context.Context, in *CancelWorkflowInstanceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error)
	InvokeWorkflow(ctx context.Context, in *InvokeWorkflowRequest, opts ...grpc.CallOption) (*InvokeWorkflowResponse, error)
	UpdateWorkflow(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*UpdateWorkflowResponse, error)
	BroadcastEvent(ctx context.Context, in *BroadcastEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetSecrets(ctx context.Context, in *GetSecretsRequest, opts ...grpc.CallOption) (*GetSecretsResponse, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StoreSecret(ctx context.Context, in *StoreSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetRegistries(ctx context.Context, in *GetRegistriesRequest, opts ...grpc.CallOption) (*GetRegistriesResponse, error)
	DeleteRegistry(ctx context.Context, in *DeleteRegistryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StoreRegistry(ctx context.Context, in *StoreRegistryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DirektivIngressClient is the client API for DirektivIngress service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDirektivIngressClient 

func NewDirektivIngressClient(cc grpc.ClientConnInterface) DirektivIngressClient

type DirektivIngressServer 

type DirektivIngressServer interface {
	AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error)
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
	GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
	AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
	GetWorkflowById(context.Context, *GetWorkflowByIdRequest) (*GetWorkflowByIdResponse, error)
	GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error)
	GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error)
	GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error)
	GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error)
	CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error)
	GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
	InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
	UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)
	BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error)
	GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)
	StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
	GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)
	DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, error)
	StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error)
	// contains filtered or unexported methods
}

DirektivIngressServer is the server API for DirektivIngress service. All implementations must embed UnimplementedDirektivIngressServer for forward compatibility

type GetNamespacesRequest 

type GetNamespacesRequest struct {
	Offset *int32 `protobuf:"varint,1,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit  *int32 `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespacesRequest.ProtoReflect.Descriptor instead.

func (*GetNamespacesRequest) GetLimit 

func (x *GetNamespacesRequest) GetLimit() int32

func (*GetNamespacesRequest) GetOffset 

func (x *GetNamespacesRequest) GetOffset() int32

func (*GetNamespacesRequest) ProtoMessage 

func (*GetNamespacesRequest) ProtoMessage()

func (*GetNamespacesRequest) ProtoReflect 

func (x *GetNamespacesRequest) ProtoReflect() protoreflect.Message

func (*GetNamespacesRequest) Reset 

func (x *GetNamespacesRequest) Reset()

func (*GetNamespacesRequest) String 

func (x *GetNamespacesRequest) String() string

type GetNamespacesResponse 

type GetNamespacesResponse struct {
	Namespaces []*GetNamespacesResponse_Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Offset     *int32                             `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit      *int32                             `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespacesResponse.ProtoReflect.Descriptor instead.

func (*GetNamespacesResponse) GetLimit 

func (x *GetNamespacesResponse) GetLimit() int32

func (*GetNamespacesResponse) GetNamespaces 

func (x *GetNamespacesResponse) GetNamespaces() []*GetNamespacesResponse_Namespace

func (*GetNamespacesResponse) GetOffset 

func (x *GetNamespacesResponse) GetOffset() int32

func (*GetNamespacesResponse) ProtoMessage 

func (*GetNamespacesResponse) ProtoMessage()

func (*GetNamespacesResponse) ProtoReflect 

func (x *GetNamespacesResponse) ProtoReflect() protoreflect.Message

func (*GetNamespacesResponse) Reset 

func (x *GetNamespacesResponse) Reset()

func (*GetNamespacesResponse) String 

func (x *GetNamespacesResponse) String() string

type GetNamespacesResponse_Namespace 

type GetNamespacesResponse_Namespace struct {
	Name      *string              `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespacesResponse_Namespace) Descriptor deprecated 

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

Deprecated: Use GetNamespacesResponse_Namespace.ProtoReflect.Descriptor instead.

func (*GetNamespacesResponse_Namespace) GetCreatedAt 

func (x *GetNamespacesResponse_Namespace) GetCreatedAt() *timestamp.Timestamp

func (*GetNamespacesResponse_Namespace) GetName 

func (x *GetNamespacesResponse_Namespace) GetName() string

func (*GetNamespacesResponse_Namespace) ProtoMessage 

func (*GetNamespacesResponse_Namespace) ProtoMessage()

func (*GetNamespacesResponse_Namespace) ProtoReflect 

func (x *GetNamespacesResponse_Namespace) ProtoReflect() protoreflect.Message

func (*GetNamespacesResponse_Namespace) Reset 

func (x *GetNamespacesResponse_Namespace) Reset()

func (*GetNamespacesResponse_Namespace) String 

func (x *GetNamespacesResponse_Namespace) String() string

type GetRegistriesRequest 

type GetRegistriesRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegistriesRequest) Descriptor deprecated 

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

Deprecated: Use GetRegistriesRequest.ProtoReflect.Descriptor instead.

func (*GetRegistriesRequest) GetNamespace 

func (x *GetRegistriesRequest) GetNamespace() string

func (*GetRegistriesRequest) ProtoMessage 

func (*GetRegistriesRequest) ProtoMessage()

func (*GetRegistriesRequest) ProtoReflect 

func (x *GetRegistriesRequest) ProtoReflect() protoreflect.Message

func (*GetRegistriesRequest) Reset 

func (x *GetRegistriesRequest) Reset()

func (*GetRegistriesRequest) String 

func (x *GetRegistriesRequest) String() string

type GetRegistriesResponse 

type GetRegistriesResponse struct {
	Registries []*GetRegistriesResponse_Registry `protobuf:"bytes,1,rep,name=registries,proto3" json:"registries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegistriesResponse) Descriptor deprecated 

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

Deprecated: Use GetRegistriesResponse.ProtoReflect.Descriptor instead.

func (*GetRegistriesResponse) GetRegistries 

func (x *GetRegistriesResponse) GetRegistries() []*GetRegistriesResponse_Registry

func (*GetRegistriesResponse) ProtoMessage 

func (*GetRegistriesResponse) ProtoMessage()

func (*GetRegistriesResponse) ProtoReflect 

func (x *GetRegistriesResponse) ProtoReflect() protoreflect.Message

func (*GetRegistriesResponse) Reset 

func (x *GetRegistriesResponse) Reset()

func (*GetRegistriesResponse) String 

func (x *GetRegistriesResponse) String() string

type GetRegistriesResponse_Registry 

type GetRegistriesResponse_Registry struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegistriesResponse_Registry) Descriptor deprecated 

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

Deprecated: Use GetRegistriesResponse_Registry.ProtoReflect.Descriptor instead.

func (*GetRegistriesResponse_Registry) GetName 

func (x *GetRegistriesResponse_Registry) GetName() string

func (*GetRegistriesResponse_Registry) ProtoMessage 

func (*GetRegistriesResponse_Registry) ProtoMessage()

func (*GetRegistriesResponse_Registry) ProtoReflect 

func (x *GetRegistriesResponse_Registry) ProtoReflect() protoreflect.Message

func (*GetRegistriesResponse_Registry) Reset 

func (x *GetRegistriesResponse_Registry) Reset()

func (*GetRegistriesResponse_Registry) String 

func (x *GetRegistriesResponse_Registry) String() string

type GetSecretsRequest 

type GetSecretsRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretsRequest.ProtoReflect.Descriptor instead.

func (*GetSecretsRequest) GetNamespace 

func (x *GetSecretsRequest) GetNamespace() string

func (*GetSecretsRequest) ProtoMessage 

func (*GetSecretsRequest) ProtoMessage()

func (*GetSecretsRequest) ProtoReflect 

func (x *GetSecretsRequest) ProtoReflect() protoreflect.Message

func (*GetSecretsRequest) Reset 

func (x *GetSecretsRequest) Reset()

func (*GetSecretsRequest) String 

func (x *GetSecretsRequest) String() string

type GetSecretsResponse 

type GetSecretsResponse struct {
	Secrets []*GetSecretsResponse_Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretsResponse.ProtoReflect.Descriptor instead.

func (*GetSecretsResponse) GetSecrets 

func (x *GetSecretsResponse) GetSecrets() []*GetSecretsResponse_Secret

func (*GetSecretsResponse) ProtoMessage 

func (*GetSecretsResponse) ProtoMessage()

func (*GetSecretsResponse) ProtoReflect 

func (x *GetSecretsResponse) ProtoReflect() protoreflect.Message

func (*GetSecretsResponse) Reset 

func (x *GetSecretsResponse) Reset()

func (*GetSecretsResponse) String 

func (x *GetSecretsResponse) String() string

type GetSecretsResponse_Secret 

type GetSecretsResponse_Secret struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecretsResponse_Secret) Descriptor deprecated 

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

Deprecated: Use GetSecretsResponse_Secret.ProtoReflect.Descriptor instead.

func (*GetSecretsResponse_Secret) GetName 

func (x *GetSecretsResponse_Secret) GetName() string

func (*GetSecretsResponse_Secret) ProtoMessage 

func (*GetSecretsResponse_Secret) ProtoMessage()

func (*GetSecretsResponse_Secret) ProtoReflect 

func (x *GetSecretsResponse_Secret) ProtoReflect() protoreflect.Message

func (*GetSecretsResponse_Secret) Reset 

func (x *GetSecretsResponse_Secret) Reset()

func (*GetSecretsResponse_Secret) String 

func (x *GetSecretsResponse_Secret) String() string

type GetWorkflowByIdRequest 

type GetWorkflowByIdRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Id        *string `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByIdRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowByIdRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowByIdRequest) GetId 

func (x *GetWorkflowByIdRequest) GetId() string

func (*GetWorkflowByIdRequest) GetNamespace 

func (x *GetWorkflowByIdRequest) GetNamespace() string

func (*GetWorkflowByIdRequest) ProtoMessage 

func (*GetWorkflowByIdRequest) ProtoMessage()

func (*GetWorkflowByIdRequest) ProtoReflect 

func (x *GetWorkflowByIdRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowByIdRequest) Reset 

func (x *GetWorkflowByIdRequest) Reset()

func (*GetWorkflowByIdRequest) String 

func (x *GetWorkflowByIdRequest) String() string

type GetWorkflowByIdResponse 

type GetWorkflowByIdResponse struct {
	Uid         *string              `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Id          *string              `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Revision    *int32               `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active      *bool                `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"`
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	Description *string              `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Workflow    []byte               `protobuf:"bytes,7,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	LogToEvents *string              `protobuf:"bytes,8,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByIdResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowByIdResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowByIdResponse) GetActive 

func (x *GetWorkflowByIdResponse) GetActive() bool

func (*GetWorkflowByIdResponse) GetCreatedAt 

func (x *GetWorkflowByIdResponse) GetCreatedAt() *timestamp.Timestamp

func (*GetWorkflowByIdResponse) GetDescription 

func (x *GetWorkflowByIdResponse) GetDescription() string

func (*GetWorkflowByIdResponse) GetId 

func (x *GetWorkflowByIdResponse) GetId() string

func (*GetWorkflowByIdResponse) GetLogToEvents added in v0.1.3 

func (x *GetWorkflowByIdResponse) GetLogToEvents() string

func (*GetWorkflowByIdResponse) GetRevision 

func (x *GetWorkflowByIdResponse) GetRevision() int32

func (*GetWorkflowByIdResponse) GetUid 

func (x *GetWorkflowByIdResponse) GetUid() string

func (*GetWorkflowByIdResponse) GetWorkflow 

func (x *GetWorkflowByIdResponse) GetWorkflow() []byte

func (*GetWorkflowByIdResponse) ProtoMessage 

func (*GetWorkflowByIdResponse) ProtoMessage()

func (*GetWorkflowByIdResponse) ProtoReflect 

func (x *GetWorkflowByIdResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowByIdResponse) Reset 

func (x *GetWorkflowByIdResponse) Reset()

func (*GetWorkflowByIdResponse) String 

func (x *GetWorkflowByIdResponse) String() string

type GetWorkflowByUidRequest 

type GetWorkflowByUidRequest struct {
	Uid *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByUidRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowByUidRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidRequest) GetUid 

func (x *GetWorkflowByUidRequest) GetUid() string

func (*GetWorkflowByUidRequest) ProtoMessage 

func (*GetWorkflowByUidRequest) ProtoMessage()

func (*GetWorkflowByUidRequest) ProtoReflect 

func (x *GetWorkflowByUidRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowByUidRequest) Reset 

func (x *GetWorkflowByUidRequest) Reset()

func (*GetWorkflowByUidRequest) String 

func (x *GetWorkflowByUidRequest) String() string

type GetWorkflowByUidResponse 

type GetWorkflowByUidResponse struct {
	Uid         *string              `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Id          *string              `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Revision    *int32               `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active      *bool                `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"`
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	Description *string              `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Workflow    []byte               `protobuf:"bytes,7,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	LogToEvents *string              `protobuf:"bytes,8,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByUidResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowByUidResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidResponse) GetActive 

func (x *GetWorkflowByUidResponse) GetActive() bool

func (*GetWorkflowByUidResponse) GetCreatedAt 

func (x *GetWorkflowByUidResponse) GetCreatedAt() *timestamp.Timestamp

func (*GetWorkflowByUidResponse) GetDescription 

func (x *GetWorkflowByUidResponse) GetDescription() string

func (*GetWorkflowByUidResponse) GetId 

func (x *GetWorkflowByUidResponse) GetId() string

func (*GetWorkflowByUidResponse) GetLogToEvents added in v0.1.3 

func (x *GetWorkflowByUidResponse) GetLogToEvents() string

func (*GetWorkflowByUidResponse) GetRevision 

func (x *GetWorkflowByUidResponse) GetRevision() int32

func (*GetWorkflowByUidResponse) GetUid 

func (x *GetWorkflowByUidResponse) GetUid() string

func (*GetWorkflowByUidResponse) GetWorkflow 

func (x *GetWorkflowByUidResponse) GetWorkflow() []byte

func (*GetWorkflowByUidResponse) ProtoMessage 

func (*GetWorkflowByUidResponse) ProtoMessage()

func (*GetWorkflowByUidResponse) ProtoReflect 

func (x *GetWorkflowByUidResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowByUidResponse) Reset 

func (x *GetWorkflowByUidResponse) Reset()

func (*GetWorkflowByUidResponse) String 

func (x *GetWorkflowByUidResponse) String() string

type GetWorkflowInstanceLogsRequest 

type GetWorkflowInstanceLogsRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"`
	Offset     *int32  `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit      *int32  `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceLogsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceLogsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceLogsRequest) GetInstanceId 

func (x *GetWorkflowInstanceLogsRequest) GetInstanceId() string

func (*GetWorkflowInstanceLogsRequest) GetLimit 

func (x *GetWorkflowInstanceLogsRequest) GetLimit() int32

func (*GetWorkflowInstanceLogsRequest) GetOffset 

func (x *GetWorkflowInstanceLogsRequest) GetOffset() int32

func (*GetWorkflowInstanceLogsRequest) ProtoMessage 

func (*GetWorkflowInstanceLogsRequest) ProtoMessage()

func (*GetWorkflowInstanceLogsRequest) ProtoReflect 

func (x *GetWorkflowInstanceLogsRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceLogsRequest) Reset 

func (x *GetWorkflowInstanceLogsRequest) Reset()

func (*GetWorkflowInstanceLogsRequest) String 

func (x *GetWorkflowInstanceLogsRequest) String() string

type GetWorkflowInstanceLogsResponse 

type GetWorkflowInstanceLogsResponse struct {
	WorkflowInstanceLogs []*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog `protobuf:"bytes,1,rep,name=workflowInstanceLogs,proto3" json:"workflowInstanceLogs,omitempty"`
	Offset               *int32                                                 `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit                *int32                                                 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceLogsResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceLogsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceLogsResponse) GetLimit 

func (x *GetWorkflowInstanceLogsResponse) GetLimit() int32

func (*GetWorkflowInstanceLogsResponse) GetOffset 

func (x *GetWorkflowInstanceLogsResponse) GetOffset() int32

func (*GetWorkflowInstanceLogsResponse) GetWorkflowInstanceLogs 

func (x *GetWorkflowInstanceLogsResponse) GetWorkflowInstanceLogs() []*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog

func (*GetWorkflowInstanceLogsResponse) ProtoMessage 

func (*GetWorkflowInstanceLogsResponse) ProtoMessage()

func (*GetWorkflowInstanceLogsResponse) ProtoReflect 

func (x *GetWorkflowInstanceLogsResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceLogsResponse) Reset 

func (x *GetWorkflowInstanceLogsResponse) Reset()

func (*GetWorkflowInstanceLogsResponse) String 

func (x *GetWorkflowInstanceLogsResponse) String() string

type GetWorkflowInstanceLogsResponse_WorkflowInstanceLog 

type GetWorkflowInstanceLogsResponse_WorkflowInstanceLog struct {
	Id        *string              `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Level     *string              `protobuf:"bytes,2,opt,name=level,proto3,oneof" json:"level,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
	Message   *string              `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"`
	Context   map[string]string    `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceLogsResponse_WorkflowInstanceLog.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext() map[string]string

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId() string

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel() string

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage() string

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp() *timestamp.Timestamp

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage 

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage()

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset()

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) String 

func (x *GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) String() string

type GetWorkflowInstanceRequest 

type GetWorkflowInstanceRequest struct {
	Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceRequest) GetId 

func (x *GetWorkflowInstanceRequest) GetId() string

func (*GetWorkflowInstanceRequest) ProtoMessage 

func (*GetWorkflowInstanceRequest) ProtoMessage()

func (*GetWorkflowInstanceRequest) ProtoReflect 

func (x *GetWorkflowInstanceRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceRequest) Reset 

func (x *GetWorkflowInstanceRequest) Reset()

func (*GetWorkflowInstanceRequest) String 

func (x *GetWorkflowInstanceRequest) String() string

type GetWorkflowInstanceResponse 

type GetWorkflowInstanceResponse struct {
	Id        *string              `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Status    *string              `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`
	InvokedBy *string              `protobuf:"bytes,3,opt,name=invokedBy,proto3,oneof" json:"invokedBy,omitempty"`
	Revision  *int32               `protobuf:"varint,4,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	BeginTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=beginTime,proto3,oneof" json:"beginTime,omitempty"`
	EndTime   *timestamp.Timestamp `protobuf:"bytes,6,opt,name=endTime,proto3,oneof" json:"endTime,omitempty"`
	Flow      []string             `protobuf:"bytes,7,rep,name=flow,proto3" json:"flow,omitempty"`
	Input     []byte               `protobuf:"bytes,8,opt,name=input,proto3,oneof" json:"input,omitempty"`
	Output    []byte               `protobuf:"bytes,9,opt,name=output,proto3,oneof" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceResponse) GetBeginTime 

func (x *GetWorkflowInstanceResponse) GetBeginTime() *timestamp.Timestamp

func (*GetWorkflowInstanceResponse) GetEndTime 

func (x *GetWorkflowInstanceResponse) GetEndTime() *timestamp.Timestamp

func (*GetWorkflowInstanceResponse) GetFlow 

func (x *GetWorkflowInstanceResponse) GetFlow() []string

func (*GetWorkflowInstanceResponse) GetId 

func (x *GetWorkflowInstanceResponse) GetId() string

func (*GetWorkflowInstanceResponse) GetInput 

func (x *GetWorkflowInstanceResponse) GetInput() []byte

func (*GetWorkflowInstanceResponse) GetInvokedBy 

func (x *GetWorkflowInstanceResponse) GetInvokedBy() string

func (*GetWorkflowInstanceResponse) GetOutput 

func (x *GetWorkflowInstanceResponse) GetOutput() []byte

func (*GetWorkflowInstanceResponse) GetRevision 

func (x *GetWorkflowInstanceResponse) GetRevision() int32

func (*GetWorkflowInstanceResponse) GetStatus 

func (x *GetWorkflowInstanceResponse) GetStatus() string

func (*GetWorkflowInstanceResponse) ProtoMessage 

func (*GetWorkflowInstanceResponse) ProtoMessage()

func (*GetWorkflowInstanceResponse) ProtoReflect 

func (x *GetWorkflowInstanceResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceResponse) Reset 

func (x *GetWorkflowInstanceResponse) Reset()

func (*GetWorkflowInstanceResponse) String 

func (x *GetWorkflowInstanceResponse) String() string

type GetWorkflowInstancesRequest 

type GetWorkflowInstancesRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Offset    *int32  `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit     *int32  `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstancesRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstancesRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstancesRequest) GetLimit 

func (x *GetWorkflowInstancesRequest) GetLimit() int32

func (*GetWorkflowInstancesRequest) GetNamespace 

func (x *GetWorkflowInstancesRequest) GetNamespace() string

func (*GetWorkflowInstancesRequest) GetOffset 

func (x *GetWorkflowInstancesRequest) GetOffset() int32

func (*GetWorkflowInstancesRequest) ProtoMessage 

func (*GetWorkflowInstancesRequest) ProtoMessage()

func (*GetWorkflowInstancesRequest) ProtoReflect 

func (x *GetWorkflowInstancesRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstancesRequest) Reset 

func (x *GetWorkflowInstancesRequest) Reset()

func (*GetWorkflowInstancesRequest) String 

func (x *GetWorkflowInstancesRequest) String() string

type GetWorkflowInstancesResponse 

type GetWorkflowInstancesResponse struct {
	WorkflowInstances []*GetWorkflowInstancesResponse_WorkflowInstance `protobuf:"bytes,1,rep,name=workflowInstances,proto3" json:"workflowInstances,omitempty"`
	Offset            *int32                                           `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit             *int32                                           `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstancesResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstancesResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstancesResponse) GetLimit 

func (x *GetWorkflowInstancesResponse) GetLimit() int32

func (*GetWorkflowInstancesResponse) GetOffset 

func (x *GetWorkflowInstancesResponse) GetOffset() int32

func (*GetWorkflowInstancesResponse) GetWorkflowInstances 

func (x *GetWorkflowInstancesResponse) GetWorkflowInstances() []*GetWorkflowInstancesResponse_WorkflowInstance

func (*GetWorkflowInstancesResponse) ProtoMessage 

func (*GetWorkflowInstancesResponse) ProtoMessage()

func (*GetWorkflowInstancesResponse) ProtoReflect 

func (x *GetWorkflowInstancesResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstancesResponse) Reset 

func (x *GetWorkflowInstancesResponse) Reset()

func (*GetWorkflowInstancesResponse) String 

func (x *GetWorkflowInstancesResponse) String() string

type GetWorkflowInstancesResponse_WorkflowInstance 

type GetWorkflowInstancesResponse_WorkflowInstance struct {
	Id        *string              `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Status    *string              `protobuf:"bytes,2,opt,name=status,proto3,oneof" json:"status,omitempty"`
	BeginTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=beginTime,proto3,oneof" json:"beginTime,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowInstancesResponse_WorkflowInstance) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstancesResponse_WorkflowInstance.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime() *timestamp.Timestamp

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetId 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetId() string

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetStatus 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) GetStatus() string

func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage 

func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage()

func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstancesResponse_WorkflowInstance) Reset 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) Reset()

func (*GetWorkflowInstancesResponse_WorkflowInstance) String 

func (x *GetWorkflowInstancesResponse_WorkflowInstance) String() string

type GetWorkflowsRequest 

type GetWorkflowsRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Offset    *int32  `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit     *int32  `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetLimit 

func (x *GetWorkflowsRequest) GetLimit() int32

func (*GetWorkflowsRequest) GetNamespace 

func (x *GetWorkflowsRequest) GetNamespace() string

func (*GetWorkflowsRequest) GetOffset 

func (x *GetWorkflowsRequest) GetOffset() int32

func (*GetWorkflowsRequest) ProtoMessage 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect 

func (x *GetWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowsRequest) Reset 

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) String 

func (x *GetWorkflowsRequest) String() string

type GetWorkflowsResponse 

type GetWorkflowsResponse struct {
	Workflows []*GetWorkflowsResponse_Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	Offset    *int32                           `protobuf:"varint,2,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	Limit     *int32                           `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	Total     *int32                           `protobuf:"varint,4,opt,name=total,proto3,oneof" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetLimit 

func (x *GetWorkflowsResponse) GetLimit() int32

func (*GetWorkflowsResponse) GetOffset 

func (x *GetWorkflowsResponse) GetOffset() int32

func (*GetWorkflowsResponse) GetTotal 

func (x *GetWorkflowsResponse) GetTotal() int32

func (*GetWorkflowsResponse) GetWorkflows 

func (x *GetWorkflowsResponse) GetWorkflows() []*GetWorkflowsResponse_Workflow

func (*GetWorkflowsResponse) ProtoMessage 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect 

func (x *GetWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowsResponse) Reset 

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) String 

func (x *GetWorkflowsResponse) String() string

type GetWorkflowsResponse_Workflow 

type GetWorkflowsResponse_Workflow struct {
	Uid         *string              `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Id          *string              `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Revision    *int32               `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active      *bool                `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"`
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	Description *string              `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
	LogToEvents *string              `protobuf:"bytes,7,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse_Workflow) Descriptor deprecated 

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

Deprecated: Use GetWorkflowsResponse_Workflow.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse_Workflow) GetActive 

func (x *GetWorkflowsResponse_Workflow) GetActive() bool

func (*GetWorkflowsResponse_Workflow) GetCreatedAt 

func (x *GetWorkflowsResponse_Workflow) GetCreatedAt() *timestamp.Timestamp

func (*GetWorkflowsResponse_Workflow) GetDescription 

func (x *GetWorkflowsResponse_Workflow) GetDescription() string

func (*GetWorkflowsResponse_Workflow) GetId 

func (x *GetWorkflowsResponse_Workflow) GetId() string

func (*GetWorkflowsResponse_Workflow) GetLogToEvents added in v0.1.3 

func (x *GetWorkflowsResponse_Workflow) GetLogToEvents() string

func (*GetWorkflowsResponse_Workflow) GetRevision 

func (x *GetWorkflowsResponse_Workflow) GetRevision() int32

func (*GetWorkflowsResponse_Workflow) GetUid 

func (x *GetWorkflowsResponse_Workflow) GetUid() string

func (*GetWorkflowsResponse_Workflow) ProtoMessage 

func (*GetWorkflowsResponse_Workflow) ProtoMessage()

func (*GetWorkflowsResponse_Workflow) ProtoReflect 

func (x *GetWorkflowsResponse_Workflow) ProtoReflect() protoreflect.Message

func (*GetWorkflowsResponse_Workflow) Reset 

func (x *GetWorkflowsResponse_Workflow) Reset()

func (*GetWorkflowsResponse_Workflow) String 

func (x *GetWorkflowsResponse_Workflow) String() string

type InvokeWorkflowRequest 

type InvokeWorkflowRequest struct {
	Namespace  *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	WorkflowId *string `protobuf:"bytes,2,opt,name=workflowId,proto3,oneof" json:"workflowId,omitempty"`
	Input      []byte  `protobuf:"bytes,3,opt,name=input,proto3,oneof" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use InvokeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*InvokeWorkflowRequest) GetInput 

func (x *InvokeWorkflowRequest) GetInput() []byte

func (*InvokeWorkflowRequest) GetNamespace 

func (x *InvokeWorkflowRequest) GetNamespace() string

func (*InvokeWorkflowRequest) GetWorkflowId 

func (x *InvokeWorkflowRequest) GetWorkflowId() string

func (*InvokeWorkflowRequest) ProtoMessage 

func (*InvokeWorkflowRequest) ProtoMessage()

func (*InvokeWorkflowRequest) ProtoReflect 

func (x *InvokeWorkflowRequest) ProtoReflect() protoreflect.Message

func (*InvokeWorkflowRequest) Reset 

func (x *InvokeWorkflowRequest) Reset()

func (*InvokeWorkflowRequest) String 

func (x *InvokeWorkflowRequest) String() string

type InvokeWorkflowResponse 

type InvokeWorkflowResponse struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use InvokeWorkflowResponse.ProtoReflect.Descriptor instead.

func (*InvokeWorkflowResponse) GetInstanceId 

func (x *InvokeWorkflowResponse) GetInstanceId() string

func (*InvokeWorkflowResponse) ProtoMessage 

func (*InvokeWorkflowResponse) ProtoMessage()

func (*InvokeWorkflowResponse) ProtoReflect 

func (x *InvokeWorkflowResponse) ProtoReflect() protoreflect.Message

func (*InvokeWorkflowResponse) Reset 

func (x *InvokeWorkflowResponse) Reset()

func (*InvokeWorkflowResponse) String 

func (x *InvokeWorkflowResponse) String() string

type StoreRegistryRequest 

type StoreRegistryRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Data      []byte  `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreRegistryRequest) Descriptor deprecated 

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

Deprecated: Use StoreRegistryRequest.ProtoReflect.Descriptor instead.

func (*StoreRegistryRequest) GetData 

func (x *StoreRegistryRequest) GetData() []byte

func (*StoreRegistryRequest) GetName 

func (x *StoreRegistryRequest) GetName() string

func (*StoreRegistryRequest) GetNamespace 

func (x *StoreRegistryRequest) GetNamespace() string

func (*StoreRegistryRequest) ProtoMessage 

func (*StoreRegistryRequest) ProtoMessage()

func (*StoreRegistryRequest) ProtoReflect 

func (x *StoreRegistryRequest) ProtoReflect() protoreflect.Message

func (*StoreRegistryRequest) Reset 

func (x *StoreRegistryRequest) Reset()

func (*StoreRegistryRequest) String 

func (x *StoreRegistryRequest) String() string

type StoreSecretRequest 

type StoreSecretRequest struct {
	Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	Name      *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Data      []byte  `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreSecretRequest) Descriptor deprecated 

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

Deprecated: Use StoreSecretRequest.ProtoReflect.Descriptor instead.

func (*StoreSecretRequest) GetData 

func (x *StoreSecretRequest) GetData() []byte

func (*StoreSecretRequest) GetName 

func (x *StoreSecretRequest) GetName() string

func (*StoreSecretRequest) GetNamespace 

func (x *StoreSecretRequest) GetNamespace() string

func (*StoreSecretRequest) ProtoMessage 

func (*StoreSecretRequest) ProtoMessage()

func (*StoreSecretRequest) ProtoReflect 

func (x *StoreSecretRequest) ProtoReflect() protoreflect.Message

func (*StoreSecretRequest) Reset 

func (x *StoreSecretRequest) Reset()

func (*StoreSecretRequest) String 

func (x *StoreSecretRequest) String() string

type UnimplementedDirektivIngressServer 

type UnimplementedDirektivIngressServer struct {
}

UnimplementedDirektivIngressServer must be embedded to have forward compatible implementations.

func (UnimplementedDirektivIngressServer) AddNamespace 

func (UnimplementedDirektivIngressServer) AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error)

func (UnimplementedDirektivIngressServer) AddWorkflow 

func (UnimplementedDirektivIngressServer) AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error)

func (UnimplementedDirektivIngressServer) BroadcastEvent 

func (UnimplementedDirektivIngressServer) BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) CancelWorkflowInstance 

func (UnimplementedDirektivIngressServer) CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) DeleteNamespace 

func (UnimplementedDirektivIngressServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)

func (UnimplementedDirektivIngressServer) DeleteRegistry 

func (UnimplementedDirektivIngressServer) DeleteRegistry(context.Context, *DeleteRegistryRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) DeleteSecret 

func (UnimplementedDirektivIngressServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) DeleteWorkflow 

func (UnimplementedDirektivIngressServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)

func (UnimplementedDirektivIngressServer) GetNamespaces 

func (UnimplementedDirektivIngressServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)

func (UnimplementedDirektivIngressServer) GetRegistries 

func (UnimplementedDirektivIngressServer) GetRegistries(context.Context, *GetRegistriesRequest) (*GetRegistriesResponse, error)

func (UnimplementedDirektivIngressServer) GetSecrets 

func (UnimplementedDirektivIngressServer) GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflowById 

func (UnimplementedDirektivIngressServer) GetWorkflowById(context.Context, *GetWorkflowByIdRequest) (*GetWorkflowByIdResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflowByUid 

func (UnimplementedDirektivIngressServer) GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflowInstance 

func (UnimplementedDirektivIngressServer) GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflowInstanceLogs 

func (UnimplementedDirektivIngressServer) GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflowInstances 

func (UnimplementedDirektivIngressServer) GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error)

func (UnimplementedDirektivIngressServer) GetWorkflows 

func (UnimplementedDirektivIngressServer) GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)

func (UnimplementedDirektivIngressServer) InvokeWorkflow 

func (UnimplementedDirektivIngressServer) InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)

func (UnimplementedDirektivIngressServer) StoreRegistry 

func (UnimplementedDirektivIngressServer) StoreRegistry(context.Context, *StoreRegistryRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) StoreSecret 

func (UnimplementedDirektivIngressServer) StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)

func (UnimplementedDirektivIngressServer) UpdateWorkflow 

func (UnimplementedDirektivIngressServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)

type UnsafeDirektivIngressServer 

type UnsafeDirektivIngressServer interface {
	// contains filtered or unexported methods
}

UnsafeDirektivIngressServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DirektivIngressServer will result in compilation errors.

type UpdateWorkflowRequest 

type UpdateWorkflowRequest struct {
	Uid         *string `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Revision    *int32  `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active      *bool   `protobuf:"varint,3,opt,name=active,proto3,oneof" json:"active,omitempty"`
	Workflow    []byte  `protobuf:"bytes,4,opt,name=workflow,proto3,oneof" json:"workflow,omitempty"`
	LogToEvents *string `protobuf:"bytes,5,opt,name=logToEvents,proto3,oneof" json:"logToEvents,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowRequest) GetActive 

func (x *UpdateWorkflowRequest) GetActive() bool

func (*UpdateWorkflowRequest) GetLogToEvents added in v0.1.3 

func (x *UpdateWorkflowRequest) GetLogToEvents() string

func (*UpdateWorkflowRequest) GetRevision 

func (x *UpdateWorkflowRequest) GetRevision() int32

func (*UpdateWorkflowRequest) GetUid 

func (x *UpdateWorkflowRequest) GetUid() string

func (*UpdateWorkflowRequest) GetWorkflow 

func (x *UpdateWorkflowRequest) GetWorkflow() []byte

func (*UpdateWorkflowRequest) ProtoMessage 

func (*UpdateWorkflowRequest) ProtoMessage()

func (*UpdateWorkflowRequest) ProtoReflect 

func (x *UpdateWorkflowRequest) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowRequest) Reset 

func (x *UpdateWorkflowRequest) Reset()

func (*UpdateWorkflowRequest) String 

func (x *UpdateWorkflowRequest) String() string

type UpdateWorkflowResponse 

type UpdateWorkflowResponse struct {
	Uid       *string              `protobuf:"bytes,1,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	Id        *string              `protobuf:"bytes,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Revision  *int32               `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Active    *bool                `protobuf:"varint,4,opt,name=active,proto3,oneof" json:"active,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowResponse) GetActive 

func (x *UpdateWorkflowResponse) GetActive() bool

func (*UpdateWorkflowResponse) GetCreatedAt 

func (x *UpdateWorkflowResponse) GetCreatedAt() *timestamp.Timestamp

func (*UpdateWorkflowResponse) GetId 

func (x *UpdateWorkflowResponse) GetId() string

func (*UpdateWorkflowResponse) GetRevision 

func (x *UpdateWorkflowResponse) GetRevision() int32

func (*UpdateWorkflowResponse) GetUid 

func (x *UpdateWorkflowResponse) GetUid() string

func (*UpdateWorkflowResponse) ProtoMessage 

func (*UpdateWorkflowResponse) ProtoMessage()

func (*UpdateWorkflowResponse) ProtoReflect 

func (x *UpdateWorkflowResponse) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowResponse) Reset 

func (x *UpdateWorkflowResponse) Reset()

func (*UpdateWorkflowResponse) String 

func (x *UpdateWorkflowResponse) String() string

Source Files

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.