ingress

package
v0.4.1 Latest Latest
Warning

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

Go to latest
Published: Sep 3, 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: "WorkflowMetrics",
			Handler:    _DirektivIngress_WorkflowMetrics_Handler,
		},
		{
			MethodName: "ListNamespaceVariables",
			Handler:    _DirektivIngress_ListNamespaceVariables_Handler,
		},
		{
			MethodName: "ListWorkflowVariables",
			Handler:    _DirektivIngress_ListWorkflowVariables_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchWorkflowInstanceLogs",
			Handler:       _DirektivIngress_WatchWorkflowInstanceLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetNamespaceVariable",
			Handler:       _DirektivIngress_GetNamespaceVariable_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetWorkflowVariable",
			Handler:       _DirektivIngress_GetWorkflowVariable_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetNamespaceVariable",
			Handler:       _DirektivIngress_SetNamespaceVariable_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SetWorkflowVariable",
			Handler:       _DirektivIngress_SetWorkflowVariable_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/ingress/protocol.proto",
}

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

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_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_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_secret_proto protoreflect.FileDescriptor
View Source
var File_pkg_ingress_update_workflow_proto protoreflect.FileDescriptor
View Source
var File_pkg_ingress_watch_instance_logs_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"`
	Timer      *int64  `protobuf:"varint,3,opt,name=timer,proto3,oneof" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastEventRequest) Descriptor deprecated

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

Deprecated: Use BroadcastEventRequest.ProtoReflect.Descriptor instead.

func (*BroadcastEventRequest) GetCloudevent

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

func (*BroadcastEventRequest) GetNamespace

func (x *BroadcastEventRequest) GetNamespace() string

func (*BroadcastEventRequest) GetTimer added in v0.4.1

func (x *BroadcastEventRequest) GetTimer() int64

func (*BroadcastEventRequest) ProtoMessage

func (*BroadcastEventRequest) ProtoMessage()

func (*BroadcastEventRequest) ProtoReflect

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

func (*BroadcastEventRequest) Reset

func (x *BroadcastEventRequest) Reset()

func (*BroadcastEventRequest) String

func (x *BroadcastEventRequest) String() string

type CancelWorkflowInstanceRequest

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

func (*CancelWorkflowInstanceRequest) Descriptor deprecated

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

Deprecated: Use CancelWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowInstanceRequest) GetId

func (*CancelWorkflowInstanceRequest) ProtoMessage

func (*CancelWorkflowInstanceRequest) ProtoMessage()

func (*CancelWorkflowInstanceRequest) ProtoReflect

func (*CancelWorkflowInstanceRequest) Reset

func (x *CancelWorkflowInstanceRequest) Reset()

func (*CancelWorkflowInstanceRequest) String

type DeleteNamespaceRequest

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

func (*DeleteNamespaceRequest) Descriptor deprecated

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetName

func (x *DeleteNamespaceRequest) GetName() string

func (*DeleteNamespaceRequest) ProtoMessage

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect

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

func (*DeleteNamespaceRequest) Reset

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String

func (x *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse

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

func (*DeleteNamespaceResponse) Descriptor deprecated

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

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) GetName

func (x *DeleteNamespaceResponse) GetName() string

func (*DeleteNamespaceResponse) ProtoMessage

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect

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

func (*DeleteNamespaceResponse) Reset

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String

func (x *DeleteNamespaceResponse) String() string

type DeleteSecretRequest

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

func (*DeleteSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetName

func (x *DeleteSecretRequest) GetName() string

func (*DeleteSecretRequest) GetNamespace

func (x *DeleteSecretRequest) GetNamespace() string

func (*DeleteSecretRequest) ProtoMessage

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect

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

func (*DeleteSecretRequest) Reset

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String

func (x *DeleteSecretRequest) String() string

type DeleteWorkflowRequest

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

func (*DeleteWorkflowRequest) Descriptor deprecated

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

Deprecated: Use DeleteWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowRequest) GetUid

func (x *DeleteWorkflowRequest) GetUid() string

func (*DeleteWorkflowRequest) ProtoMessage

func (*DeleteWorkflowRequest) ProtoMessage()

func (*DeleteWorkflowRequest) ProtoReflect

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

func (*DeleteWorkflowRequest) Reset

func (x *DeleteWorkflowRequest) Reset()

func (*DeleteWorkflowRequest) String

func (x *DeleteWorkflowRequest) String() string

type DeleteWorkflowResponse

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

func (*DeleteWorkflowResponse) Descriptor deprecated

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

Deprecated: Use DeleteWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowResponse) GetUid

func (x *DeleteWorkflowResponse) GetUid() string

func (*DeleteWorkflowResponse) ProtoMessage

func (*DeleteWorkflowResponse) ProtoMessage()

func (*DeleteWorkflowResponse) ProtoReflect

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

func (*DeleteWorkflowResponse) Reset

func (x *DeleteWorkflowResponse) Reset()

func (*DeleteWorkflowResponse) String

func (x *DeleteWorkflowResponse) String() string

type DirektivIngressClient

type DirektivIngressClient interface {
	AddNamespace(ctx context.Context, in *AddNamespaceRequest, opts ...grpc.CallOption) (*AddNamespaceResponse, error)
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
	GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, error)
	AddWorkflow(ctx context.Context, in *AddWorkflowRequest, opts ...grpc.CallOption) (*AddWorkflowResponse, error)
	DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*DeleteWorkflowResponse, error)
	GetWorkflowByName(ctx context.Context, in *GetWorkflowByNameRequest, opts ...grpc.CallOption) (*GetWorkflowByNameResponse, error)
	GetWorkflowByUid(ctx context.Context, in *GetWorkflowByUidRequest, opts ...grpc.CallOption) (*GetWorkflowByUidResponse, error)
	GetWorkflowInstance(ctx context.Context, in *GetWorkflowInstanceRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceResponse, error)
	GetWorkflowInstances(ctx context.Context, in *GetWorkflowInstancesRequest, opts ...grpc.CallOption) (*GetWorkflowInstancesResponse, error)
	GetNamespaceLogs(ctx context.Context, in *GetNamespaceLogsRequest, opts ...grpc.CallOption) (*GetNamespaceLogsResponse, error)
	GetInstancesByWorkflow(ctx context.Context, in *GetInstancesByWorkflowRequest, opts ...grpc.CallOption) (*GetInstancesByWorkflowResponse, error)
	GetWorkflowInstanceLogs(ctx context.Context, in *GetWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceLogsResponse, error)
	WatchWorkflowInstanceLogs(ctx context.Context, in *WatchWorkflowInstanceLogsRequest, opts ...grpc.CallOption) (DirektivIngress_WatchWorkflowInstanceLogsClient, error)
	CancelWorkflowInstance(ctx context.Context, in *CancelWorkflowInstanceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetWorkflows(ctx context.Context, in *GetWorkflowsRequest, opts ...grpc.CallOption) (*GetWorkflowsResponse, error)
	InvokeWorkflow(ctx context.Context, in *InvokeWorkflowRequest, opts ...grpc.CallOption) (*InvokeWorkflowResponse, error)
	UpdateWorkflow(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*UpdateWorkflowResponse, error)
	BroadcastEvent(ctx context.Context, in *BroadcastEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetSecrets(ctx context.Context, in *GetSecretsRequest, opts ...grpc.CallOption) (*GetSecretsResponse, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StoreSecret(ctx context.Context, in *StoreSecretRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	WorkflowMetrics(ctx context.Context, in *WorkflowMetricsRequest, opts ...grpc.CallOption) (*WorkflowMetricsResponse, error)
	ListNamespaceVariables(ctx context.Context, in *ListNamespaceVariablesRequest, opts ...grpc.CallOption) (*ListNamespaceVariablesResponse, error)
	ListWorkflowVariables(ctx context.Context, in *ListWorkflowVariablesRequest, opts ...grpc.CallOption) (*ListWorkflowVariablesResponse, error)
	GetNamespaceVariable(ctx context.Context, in *GetNamespaceVariableRequest, opts ...grpc.CallOption) (DirektivIngress_GetNamespaceVariableClient, error)
	GetWorkflowVariable(ctx context.Context, in *GetWorkflowVariableRequest, opts ...grpc.CallOption) (DirektivIngress_GetWorkflowVariableClient, error)
	SetNamespaceVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivIngress_SetNamespaceVariableClient, error)
	SetWorkflowVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivIngress_SetWorkflowVariableClient, error)
}

DirektivIngressClient is the client API for DirektivIngress service.

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

type DirektivIngressServer

type DirektivIngressServer interface {
	AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error)
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
	GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
	AddWorkflow(context.Context, *AddWorkflowRequest) (*AddWorkflowResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*DeleteWorkflowResponse, error)
	GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*GetWorkflowByNameResponse, error)
	GetWorkflowByUid(context.Context, *GetWorkflowByUidRequest) (*GetWorkflowByUidResponse, error)
	GetWorkflowInstance(context.Context, *GetWorkflowInstanceRequest) (*GetWorkflowInstanceResponse, error)
	GetWorkflowInstances(context.Context, *GetWorkflowInstancesRequest) (*GetWorkflowInstancesResponse, error)
	GetNamespaceLogs(context.Context, *GetNamespaceLogsRequest) (*GetNamespaceLogsResponse, error)
	GetInstancesByWorkflow(context.Context, *GetInstancesByWorkflowRequest) (*GetInstancesByWorkflowResponse, error)
	GetWorkflowInstanceLogs(context.Context, *GetWorkflowInstanceLogsRequest) (*GetWorkflowInstanceLogsResponse, error)
	WatchWorkflowInstanceLogs(*WatchWorkflowInstanceLogsRequest, DirektivIngress_WatchWorkflowInstanceLogsServer) error
	CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*empty.Empty, error)
	GetWorkflows(context.Context, *GetWorkflowsRequest) (*GetWorkflowsResponse, error)
	InvokeWorkflow(context.Context, *InvokeWorkflowRequest) (*InvokeWorkflowResponse, error)
	UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*UpdateWorkflowResponse, error)
	BroadcastEvent(context.Context, *BroadcastEventRequest) (*empty.Empty, error)
	GetSecrets(context.Context, *GetSecretsRequest) (*GetSecretsResponse, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*empty.Empty, error)
	StoreSecret(context.Context, *StoreSecretRequest) (*empty.Empty, error)
	WorkflowMetrics(context.Context, *WorkflowMetricsRequest) (*WorkflowMetricsResponse, error)
	ListNamespaceVariables(context.Context, *ListNamespaceVariablesRequest) (*ListNamespaceVariablesResponse, error)
	ListWorkflowVariables(context.Context, *ListWorkflowVariablesRequest) (*ListWorkflowVariablesResponse, error)
	GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivIngress_GetNamespaceVariableServer) error
	GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivIngress_GetWorkflowVariableServer) error
	SetNamespaceVariable(DirektivIngress_SetNamespaceVariableServer) error
	SetWorkflowVariable(DirektivIngress_SetWorkflowVariableServer) error
	// contains filtered or unexported methods
}

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

type DirektivIngress_GetNamespaceVariableClient added in v0.2.3

type DirektivIngress_GetNamespaceVariableClient interface {
	Recv() (*GetNamespaceVariableResponse, error)
	grpc.ClientStream
}

type DirektivIngress_GetNamespaceVariableServer added in v0.2.3

type DirektivIngress_GetNamespaceVariableServer interface {
	Send(*GetNamespaceVariableResponse) error
	grpc.ServerStream
}

type DirektivIngress_GetWorkflowVariableClient added in v0.2.3

type DirektivIngress_GetWorkflowVariableClient interface {
	Recv() (*GetWorkflowVariableResponse, error)
	grpc.ClientStream
}

type DirektivIngress_GetWorkflowVariableServer added in v0.2.3

type DirektivIngress_GetWorkflowVariableServer interface {
	Send(*GetWorkflowVariableResponse) error
	grpc.ServerStream
}

type DirektivIngress_SetNamespaceVariableClient added in v0.2.3

type DirektivIngress_SetNamespaceVariableClient interface {
	Send(*SetNamespaceVariableRequest) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type DirektivIngress_SetNamespaceVariableServer added in v0.2.3

type DirektivIngress_SetNamespaceVariableServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*SetNamespaceVariableRequest, error)
	grpc.ServerStream
}

type DirektivIngress_SetWorkflowVariableClient added in v0.2.3

type DirektivIngress_SetWorkflowVariableClient interface {
	Send(*SetWorkflowVariableRequest) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type DirektivIngress_SetWorkflowVariableServer added in v0.2.3

type DirektivIngress_SetWorkflowVariableServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*SetWorkflowVariableRequest, error)
	grpc.ServerStream
}

type DirektivIngress_WatchWorkflowInstanceLogsClient added in v0.4.1

type DirektivIngress_WatchWorkflowInstanceLogsClient interface {
	Recv() (*WatchWorkflowInstanceLogsResponse, error)
	grpc.ClientStream
}

type DirektivIngress_WatchWorkflowInstanceLogsServer added in v0.4.1

type DirektivIngress_WatchWorkflowInstanceLogsServer interface {
	Send(*WatchWorkflowInstanceLogsResponse) error
	grpc.ServerStream
}

type GetInstancesByWorkflowRequest added in v0.2.1

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

func (*GetInstancesByWorkflowRequest) Descriptor deprecated added in v0.2.1

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

Deprecated: Use GetInstancesByWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetInstancesByWorkflowRequest) GetLimit added in v0.2.1

func (x *GetInstancesByWorkflowRequest) GetLimit() int32

func (*GetInstancesByWorkflowRequest) GetNamespace added in v0.2.1

func (x *GetInstancesByWorkflowRequest) GetNamespace() string

func (*GetInstancesByWorkflowRequest) GetOffset added in v0.2.1

func (x *GetInstancesByWorkflowRequest) GetOffset() int32

func (*GetInstancesByWorkflowRequest) GetWorkflow added in v0.2.1

func (x *GetInstancesByWorkflowRequest) GetWorkflow() string

func (*GetInstancesByWorkflowRequest) ProtoMessage added in v0.2.1

func (*GetInstancesByWorkflowRequest) ProtoMessage()

func (*GetInstancesByWorkflowRequest) ProtoReflect added in v0.2.1

func (*GetInstancesByWorkflowRequest) Reset added in v0.2.1

func (x *GetInstancesByWorkflowRequest) Reset()

func (*GetInstancesByWorkflowRequest) String added in v0.2.1

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 (*GetInstancesByWorkflowResponse) ProtoMessage added in v0.2.1

func (*GetInstancesByWorkflowResponse) ProtoMessage()

func (*GetInstancesByWorkflowResponse) ProtoReflect added in v0.2.1

func (*GetInstancesByWorkflowResponse) Reset added in v0.2.1

func (x *GetInstancesByWorkflowResponse) Reset()

func (*GetInstancesByWorkflowResponse) String added in v0.2.1

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

Deprecated: Use GetInstancesByWorkflowResponse_WorkflowInstance.ProtoReflect.Descriptor instead.

func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetBeginTime added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetId added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) GetStatus added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoMessage added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) ProtoReflect added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) Reset added in v0.2.1

func (*GetInstancesByWorkflowResponse_WorkflowInstance) String added in v0.2.1

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 (*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 (*GetNamespaceLogsResponse_NamespaceLog) GetId added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) GetLevel added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) GetMessage added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) GetTimestamp added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) ProtoMessage added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) ProtoMessage()

func (*GetNamespaceLogsResponse_NamespaceLog) ProtoReflect added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) Reset added in v0.2.5

func (*GetNamespaceLogsResponse_NamespaceLog) String added in v0.2.5

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 (*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 (*GetNamespaceVariableResponse) Reset added in v0.2.3

func (x *GetNamespaceVariableResponse) Reset()

func (*GetNamespaceVariableResponse) String added in v0.2.3

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 (*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 (*GetNamespacesResponse_Namespace) GetName

func (*GetNamespacesResponse_Namespace) ProtoMessage

func (*GetNamespacesResponse_Namespace) ProtoMessage()

func (*GetNamespacesResponse_Namespace) ProtoReflect

func (*GetNamespacesResponse_Namespace) Reset

func (*GetNamespacesResponse_Namespace) 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 (*GetSecretsResponse_Secret) Reset

func (x *GetSecretsResponse_Secret) Reset()

func (*GetSecretsResponse_Secret) String

func (x *GetSecretsResponse_Secret) String() string

type GetWorkflowByNameRequest added in v0.2.1

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

func (*GetWorkflowByNameRequest) Descriptor deprecated added in v0.2.1

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

Deprecated: Use GetWorkflowByNameRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameRequest) GetGetReferences added in v0.3.3

func (x *GetWorkflowByNameRequest) GetGetReferences() bool

func (*GetWorkflowByNameRequest) GetName added in v0.2.1

func (x *GetWorkflowByNameRequest) GetName() string

func (*GetWorkflowByNameRequest) GetNamespace added in v0.2.1

func (x *GetWorkflowByNameRequest) GetNamespace() string

func (*GetWorkflowByNameRequest) ProtoMessage added in v0.2.1

func (*GetWorkflowByNameRequest) ProtoMessage()

func (*GetWorkflowByNameRequest) ProtoReflect added in v0.2.1

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

func (*GetWorkflowByNameRequest) Reset added in v0.2.1

func (x *GetWorkflowByNameRequest) Reset()

func (*GetWorkflowByNameRequest) String added in v0.2.1

func (x *GetWorkflowByNameRequest) String() string

type GetWorkflowByNameResponse added in v0.2.1

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

func (*GetWorkflowByNameResponse) Descriptor deprecated added in v0.2.1

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

Deprecated: Use GetWorkflowByNameResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameResponse) GetActive added in v0.2.1

func (x *GetWorkflowByNameResponse) GetActive() bool

func (*GetWorkflowByNameResponse) GetCreatedAt added in v0.2.1

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

func (*GetWorkflowByNameResponse) GetDescription added in v0.2.1

func (x *GetWorkflowByNameResponse) GetDescription() string

func (*GetWorkflowByNameResponse) GetLogToEvents added in v0.2.1

func (x *GetWorkflowByNameResponse) GetLogToEvents() string

func (*GetWorkflowByNameResponse) GetName added in v0.2.1

func (x *GetWorkflowByNameResponse) GetName() string

func (*GetWorkflowByNameResponse) GetReferences added in v0.3.3

func (*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 (*GetWorkflowByNameResponse) Reset added in v0.2.1

func (x *GetWorkflowByNameResponse) Reset()

func (*GetWorkflowByNameResponse) String added in v0.2.1

func (x *GetWorkflowByNameResponse) String() string

type GetWorkflowByNameResponse_References added in v0.3.3

type GetWorkflowByNameResponse_References struct {
	Secrets   []*GetWorkflowByNameResponse_References_Secret   `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	Variables []*GetWorkflowByNameResponse_References_Variable `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByNameResponse_References) Descriptor deprecated added in v0.3.3

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

Deprecated: Use GetWorkflowByNameResponse_References.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameResponse_References) GetSecrets added in v0.3.3

func (*GetWorkflowByNameResponse_References) GetVariables added in v0.3.3

func (*GetWorkflowByNameResponse_References) ProtoMessage added in v0.3.3

func (*GetWorkflowByNameResponse_References) ProtoMessage()

func (*GetWorkflowByNameResponse_References) ProtoReflect added in v0.3.3

func (*GetWorkflowByNameResponse_References) Reset added in v0.3.3

func (*GetWorkflowByNameResponse_References) String added in v0.3.3

type GetWorkflowByNameResponse_References_Secret added in v0.3.3

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

func (*GetWorkflowByNameResponse_References_Secret) Descriptor deprecated added in v0.3.3

Deprecated: Use GetWorkflowByNameResponse_References_Secret.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameResponse_References_Secret) GetKey added in v0.3.3

func (*GetWorkflowByNameResponse_References_Secret) ProtoMessage added in v0.3.3

func (*GetWorkflowByNameResponse_References_Secret) ProtoReflect added in v0.3.3

func (*GetWorkflowByNameResponse_References_Secret) Reset added in v0.3.3

func (*GetWorkflowByNameResponse_References_Secret) String added in v0.3.3

type GetWorkflowByNameResponse_References_Variable added in v0.3.3

type GetWorkflowByNameResponse_References_Variable struct {
	Key        *string  `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"`
	Scope      *string  `protobuf:"bytes,2,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	Operations []string `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByNameResponse_References_Variable) Descriptor deprecated added in v0.3.3

Deprecated: Use GetWorkflowByNameResponse_References_Variable.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameResponse_References_Variable) GetKey added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) GetOperations added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) GetScope added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) ProtoMessage added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) ProtoReflect added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) Reset added in v0.3.3

func (*GetWorkflowByNameResponse_References_Variable) String added in v0.3.3

type GetWorkflowByUidRequest

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

func (*GetWorkflowByUidRequest) Descriptor deprecated

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

Deprecated: Use GetWorkflowByUidRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidRequest) GetGetReferences added in v0.3.3

func (x *GetWorkflowByUidRequest) GetGetReferences() bool

func (*GetWorkflowByUidRequest) GetUid

func (x *GetWorkflowByUidRequest) GetUid() string

func (*GetWorkflowByUidRequest) ProtoMessage

func (*GetWorkflowByUidRequest) ProtoMessage()

func (*GetWorkflowByUidRequest) ProtoReflect

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

func (*GetWorkflowByUidRequest) Reset

func (x *GetWorkflowByUidRequest) Reset()

func (*GetWorkflowByUidRequest) String

func (x *GetWorkflowByUidRequest) String() string

type GetWorkflowByUidResponse

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

func (*GetWorkflowByUidResponse) Descriptor deprecated

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

Deprecated: Use GetWorkflowByUidResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidResponse) GetActive

func (x *GetWorkflowByUidResponse) GetActive() bool

func (*GetWorkflowByUidResponse) GetCreatedAt

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

func (*GetWorkflowByUidResponse) GetDescription

func (x *GetWorkflowByUidResponse) GetDescription() string

func (*GetWorkflowByUidResponse) GetId

func (x *GetWorkflowByUidResponse) GetId() string

func (*GetWorkflowByUidResponse) GetLogToEvents added in v0.1.3

func (x *GetWorkflowByUidResponse) GetLogToEvents() string

func (*GetWorkflowByUidResponse) GetReferences added in v0.3.3

func (*GetWorkflowByUidResponse) GetRevision

func (x *GetWorkflowByUidResponse) GetRevision() int32

func (*GetWorkflowByUidResponse) GetUid

func (x *GetWorkflowByUidResponse) GetUid() string

func (*GetWorkflowByUidResponse) GetWorkflow

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

func (*GetWorkflowByUidResponse) ProtoMessage

func (*GetWorkflowByUidResponse) ProtoMessage()

func (*GetWorkflowByUidResponse) ProtoReflect

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

func (*GetWorkflowByUidResponse) Reset

func (x *GetWorkflowByUidResponse) Reset()

func (*GetWorkflowByUidResponse) String

func (x *GetWorkflowByUidResponse) String() string

type GetWorkflowByUidResponse_References added in v0.3.3

type GetWorkflowByUidResponse_References struct {
	Secrets   []*GetWorkflowByUidResponse_References_Secret   `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	Variables []*GetWorkflowByUidResponse_References_Variable `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByUidResponse_References) Descriptor deprecated added in v0.3.3

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

Deprecated: Use GetWorkflowByUidResponse_References.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidResponse_References) GetSecrets added in v0.3.3

func (*GetWorkflowByUidResponse_References) GetVariables added in v0.3.3

func (*GetWorkflowByUidResponse_References) ProtoMessage added in v0.3.3

func (*GetWorkflowByUidResponse_References) ProtoMessage()

func (*GetWorkflowByUidResponse_References) ProtoReflect added in v0.3.3

func (*GetWorkflowByUidResponse_References) Reset added in v0.3.3

func (*GetWorkflowByUidResponse_References) String added in v0.3.3

type GetWorkflowByUidResponse_References_Secret added in v0.3.3

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

func (*GetWorkflowByUidResponse_References_Secret) Descriptor deprecated added in v0.3.3

Deprecated: Use GetWorkflowByUidResponse_References_Secret.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidResponse_References_Secret) GetKey added in v0.3.3

func (*GetWorkflowByUidResponse_References_Secret) ProtoMessage added in v0.3.3

func (*GetWorkflowByUidResponse_References_Secret) ProtoReflect added in v0.3.3

func (*GetWorkflowByUidResponse_References_Secret) Reset added in v0.3.3

func (*GetWorkflowByUidResponse_References_Secret) String added in v0.3.3

type GetWorkflowByUidResponse_References_Variable added in v0.3.3

type GetWorkflowByUidResponse_References_Variable struct {
	Key        *string  `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"`
	Scope      *string  `protobuf:"bytes,2,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	Operations []string `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowByUidResponse_References_Variable) Descriptor deprecated added in v0.3.3

Deprecated: Use GetWorkflowByUidResponse_References_Variable.ProtoReflect.Descriptor instead.

func (*GetWorkflowByUidResponse_References_Variable) GetKey added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) GetOperations added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) GetScope added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) ProtoMessage added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) ProtoReflect added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) Reset added in v0.3.3

func (*GetWorkflowByUidResponse_References_Variable) String added in v0.3.3

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 (*GetWorkflowInstanceLogsRequest) Reset

func (x *GetWorkflowInstanceLogsRequest) Reset()

func (*GetWorkflowInstanceLogsRequest) 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 (*GetWorkflowInstanceLogsResponse) ProtoMessage

func (*GetWorkflowInstanceLogsResponse) ProtoMessage()

func (*GetWorkflowInstanceLogsResponse) ProtoReflect

func (*GetWorkflowInstanceLogsResponse) Reset

func (*GetWorkflowInstanceLogsResponse) 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

Deprecated: Use GetWorkflowInstanceLogsResponse_WorkflowInstanceLog.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetContext

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetId

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetLevel

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetMessage

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) GetTimestamp

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoMessage

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) ProtoReflect

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) Reset

func (*GetWorkflowInstanceLogsResponse_WorkflowInstanceLog) 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 (*GetWorkflowInstanceRequest) ProtoMessage

func (*GetWorkflowInstanceRequest) ProtoMessage()

func (*GetWorkflowInstanceRequest) ProtoReflect

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 (*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 (*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 (*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 (*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 (*GetWorkflowInstancesResponse) ProtoMessage

func (*GetWorkflowInstancesResponse) ProtoMessage()

func (*GetWorkflowInstancesResponse) ProtoReflect

func (*GetWorkflowInstancesResponse) Reset

func (x *GetWorkflowInstancesResponse) Reset()

func (*GetWorkflowInstancesResponse) 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

Deprecated: Use GetWorkflowInstancesResponse_WorkflowInstance.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetBeginTime

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetId

func (*GetWorkflowInstancesResponse_WorkflowInstance) GetStatus

func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoMessage

func (*GetWorkflowInstancesResponse_WorkflowInstance) ProtoReflect

func (*GetWorkflowInstancesResponse_WorkflowInstance) Reset

func (*GetWorkflowInstancesResponse_WorkflowInstance) 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 (*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 (*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 (*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 (*GetWorkflowsResponse_Workflow) GetDescription

func (x *GetWorkflowsResponse_Workflow) GetDescription() string

func (*GetWorkflowsResponse_Workflow) GetId

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 (*GetWorkflowsResponse_Workflow) ProtoMessage

func (*GetWorkflowsResponse_Workflow) ProtoMessage()

func (*GetWorkflowsResponse_Workflow) ProtoReflect

func (*GetWorkflowsResponse_Workflow) Reset

func (x *GetWorkflowsResponse_Workflow) Reset()

func (*GetWorkflowsResponse_Workflow) String

type InvokeWorkflowRequest

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

func (*InvokeWorkflowRequest) Descriptor deprecated

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

Deprecated: Use InvokeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*InvokeWorkflowRequest) GetInput

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

func (*InvokeWorkflowRequest) GetName added in v0.2.1

func (x *InvokeWorkflowRequest) GetName() string

func (*InvokeWorkflowRequest) GetNamespace

func (x *InvokeWorkflowRequest) GetNamespace() string

func (*InvokeWorkflowRequest) GetWait added in v0.2.5

func (x *InvokeWorkflowRequest) GetWait() bool

func (*InvokeWorkflowRequest) ProtoMessage

func (*InvokeWorkflowRequest) ProtoMessage()

func (*InvokeWorkflowRequest) ProtoReflect

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

func (*InvokeWorkflowRequest) Reset

func (x *InvokeWorkflowRequest) Reset()

func (*InvokeWorkflowRequest) String

func (x *InvokeWorkflowRequest) String() string

type InvokeWorkflowResponse

type InvokeWorkflowResponse struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"`
	Output     []byte  `protobuf:"bytes,2,opt,name=output,proto3,oneof" json:"output,omitempty"`
	ErrorCode  *string `protobuf:"bytes,3,opt,name=errorCode,proto3,oneof" json:"errorCode,omitempty"`
	ErrorMsg   *string `protobuf:"bytes,4,opt,name=errorMsg,proto3,oneof" json:"errorMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeWorkflowResponse) Descriptor deprecated

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

Deprecated: Use InvokeWorkflowResponse.ProtoReflect.Descriptor instead.

func (*InvokeWorkflowResponse) GetErrorCode added in v0.3.4

func (x *InvokeWorkflowResponse) GetErrorCode() string

func (*InvokeWorkflowResponse) GetErrorMsg added in v0.3.4

func (x *InvokeWorkflowResponse) GetErrorMsg() string

func (*InvokeWorkflowResponse) GetInstanceId

func (x *InvokeWorkflowResponse) GetInstanceId() string

func (*InvokeWorkflowResponse) GetOutput added in v0.2.5

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

func (*InvokeWorkflowResponse) ProtoMessage

func (*InvokeWorkflowResponse) ProtoMessage()

func (*InvokeWorkflowResponse) ProtoReflect

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

func (*InvokeWorkflowResponse) Reset

func (x *InvokeWorkflowResponse) Reset()

func (*InvokeWorkflowResponse) String

func (x *InvokeWorkflowResponse) String() string

type ListNamespaceVariablesRequest added in v0.2.3

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

func (*ListNamespaceVariablesRequest) Descriptor deprecated added in v0.2.3

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

Deprecated: Use ListNamespaceVariablesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespaceVariablesRequest) GetNamespace added in v0.2.3

func (x *ListNamespaceVariablesRequest) GetNamespace() string

func (*ListNamespaceVariablesRequest) ProtoMessage added in v0.2.3

func (*ListNamespaceVariablesRequest) ProtoMessage()

func (*ListNamespaceVariablesRequest) ProtoReflect added in v0.2.3

func (*ListNamespaceVariablesRequest) Reset added in v0.2.3

func (x *ListNamespaceVariablesRequest) Reset()

func (*ListNamespaceVariablesRequest) String added in v0.2.3

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 (*ListNamespaceVariablesResponse) ProtoMessage added in v0.2.3

func (*ListNamespaceVariablesResponse) ProtoMessage()

func (*ListNamespaceVariablesResponse) ProtoReflect added in v0.2.3

func (*ListNamespaceVariablesResponse) Reset added in v0.2.3

func (x *ListNamespaceVariablesResponse) Reset()

func (*ListNamespaceVariablesResponse) String added in v0.2.3

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 (*ListNamespaceVariablesResponse_Variable) GetSize added in v0.2.3

func (*ListNamespaceVariablesResponse_Variable) ProtoMessage added in v0.2.3

func (*ListNamespaceVariablesResponse_Variable) ProtoReflect added in v0.2.3

func (*ListNamespaceVariablesResponse_Variable) Reset added in v0.2.3

func (*ListNamespaceVariablesResponse_Variable) String added in v0.2.3

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 (*ListWorkflowVariablesRequest) Reset added in v0.2.3

func (x *ListWorkflowVariablesRequest) Reset()

func (*ListWorkflowVariablesRequest) String added in v0.2.3

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 (*ListWorkflowVariablesResponse) ProtoMessage added in v0.2.3

func (*ListWorkflowVariablesResponse) ProtoMessage()

func (*ListWorkflowVariablesResponse) ProtoReflect added in v0.2.3

func (*ListWorkflowVariablesResponse) Reset added in v0.2.3

func (x *ListWorkflowVariablesResponse) Reset()

func (*ListWorkflowVariablesResponse) String added in v0.2.3

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 (*ListWorkflowVariablesResponse_Variable) GetSize added in v0.2.3

func (*ListWorkflowVariablesResponse_Variable) ProtoMessage added in v0.2.3

func (*ListWorkflowVariablesResponse_Variable) ProtoReflect added in v0.2.3

func (*ListWorkflowVariablesResponse_Variable) Reset added in v0.2.3

func (*ListWorkflowVariablesResponse_Variable) String added in v0.2.3

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 (*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 (*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 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) AddWorkflow

func (UnimplementedDirektivIngressServer) BroadcastEvent

func (UnimplementedDirektivIngressServer) CancelWorkflowInstance

func (UnimplementedDirektivIngressServer) DeleteNamespace

func (UnimplementedDirektivIngressServer) DeleteSecret

func (UnimplementedDirektivIngressServer) DeleteWorkflow

func (UnimplementedDirektivIngressServer) GetInstancesByWorkflow added in v0.2.1

func (UnimplementedDirektivIngressServer) GetNamespaceLogs added in v0.2.5

func (UnimplementedDirektivIngressServer) GetNamespaceVariable added in v0.2.3

func (UnimplementedDirektivIngressServer) GetNamespaces

func (UnimplementedDirektivIngressServer) GetSecrets

func (UnimplementedDirektivIngressServer) GetWorkflowByName added in v0.2.1

func (UnimplementedDirektivIngressServer) GetWorkflowByUid

func (UnimplementedDirektivIngressServer) GetWorkflowInstance

func (UnimplementedDirektivIngressServer) GetWorkflowVariable added in v0.2.3

func (UnimplementedDirektivIngressServer) GetWorkflows

func (UnimplementedDirektivIngressServer) InvokeWorkflow

func (UnimplementedDirektivIngressServer) ListNamespaceVariables added in v0.2.3

func (UnimplementedDirektivIngressServer) ListWorkflowVariables added in v0.2.3

func (UnimplementedDirektivIngressServer) SetNamespaceVariable added in v0.2.3

func (UnimplementedDirektivIngressServer) SetWorkflowVariable added in v0.2.3

func (UnimplementedDirektivIngressServer) StoreSecret

func (UnimplementedDirektivIngressServer) UpdateWorkflow

func (UnimplementedDirektivIngressServer) WatchWorkflowInstanceLogs added in v0.4.1

func (UnimplementedDirektivIngressServer) WorkflowMetrics added in v0.2.1

type UnsafeDirektivIngressServer

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

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

type UpdateWorkflowRequest

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

func (*UpdateWorkflowRequest) Descriptor deprecated

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

Deprecated: Use UpdateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowRequest) GetActive

func (x *UpdateWorkflowRequest) GetActive() bool

func (*UpdateWorkflowRequest) GetLogToEvents added in v0.1.3

func (x *UpdateWorkflowRequest) GetLogToEvents() string

func (*UpdateWorkflowRequest) GetRevision

func (x *UpdateWorkflowRequest) GetRevision() int32

func (*UpdateWorkflowRequest) GetUid

func (x *UpdateWorkflowRequest) GetUid() string

func (*UpdateWorkflowRequest) GetWorkflow

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

func (*UpdateWorkflowRequest) ProtoMessage

func (*UpdateWorkflowRequest) ProtoMessage()

func (*UpdateWorkflowRequest) ProtoReflect

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

func (*UpdateWorkflowRequest) Reset

func (x *UpdateWorkflowRequest) Reset()

func (*UpdateWorkflowRequest) String

func (x *UpdateWorkflowRequest) String() string

type UpdateWorkflowResponse

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

func (*UpdateWorkflowResponse) Descriptor deprecated

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

Deprecated: Use UpdateWorkflowResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowResponse) GetActive

func (x *UpdateWorkflowResponse) GetActive() bool

func (*UpdateWorkflowResponse) GetCreatedAt

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

func (*UpdateWorkflowResponse) GetId

func (x *UpdateWorkflowResponse) GetId() string

func (*UpdateWorkflowResponse) GetRevision

func (x *UpdateWorkflowResponse) GetRevision() int32

func (*UpdateWorkflowResponse) GetUid

func (x *UpdateWorkflowResponse) GetUid() string

func (*UpdateWorkflowResponse) ProtoMessage

func (*UpdateWorkflowResponse) ProtoMessage()

func (*UpdateWorkflowResponse) ProtoReflect

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

func (*UpdateWorkflowResponse) Reset

func (x *UpdateWorkflowResponse) Reset()

func (*UpdateWorkflowResponse) String

func (x *UpdateWorkflowResponse) String() string

type WatchWorkflowInstanceLogsRequest added in v0.4.1

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

func (*WatchWorkflowInstanceLogsRequest) Descriptor deprecated added in v0.4.1

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

Deprecated: Use WatchWorkflowInstanceLogsRequest.ProtoReflect.Descriptor instead.

func (*WatchWorkflowInstanceLogsRequest) GetInstanceId added in v0.4.1

func (x *WatchWorkflowInstanceLogsRequest) GetInstanceId() string

func (*WatchWorkflowInstanceLogsRequest) ProtoMessage added in v0.4.1

func (*WatchWorkflowInstanceLogsRequest) ProtoMessage()

func (*WatchWorkflowInstanceLogsRequest) ProtoReflect added in v0.4.1

func (*WatchWorkflowInstanceLogsRequest) Reset added in v0.4.1

func (*WatchWorkflowInstanceLogsRequest) String added in v0.4.1

type WatchWorkflowInstanceLogsResponse added in v0.4.1

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

func (*WatchWorkflowInstanceLogsResponse) Descriptor deprecated added in v0.4.1

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

Deprecated: Use WatchWorkflowInstanceLogsResponse.ProtoReflect.Descriptor instead.

func (*WatchWorkflowInstanceLogsResponse) GetContext added in v0.4.1

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

func (*WatchWorkflowInstanceLogsResponse) GetId added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) GetLevel added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) GetMessage added in v0.4.1

func (x *WatchWorkflowInstanceLogsResponse) GetMessage() string

func (*WatchWorkflowInstanceLogsResponse) GetTimestamp added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) ProtoMessage added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) ProtoMessage()

func (*WatchWorkflowInstanceLogsResponse) ProtoReflect added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) Reset added in v0.4.1

func (*WatchWorkflowInstanceLogsResponse) String added in v0.4.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL