flow

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: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DirektivFlow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flow.DirektivFlow",
	HandlerType: (*DirektivFlowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportActionResults",
			Handler:    _DirektivFlow_ReportActionResults_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _DirektivFlow_Resume_Handler,
		},
		{
			MethodName: "ActionLog",
			Handler:    _DirektivFlow_ActionLog_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetNamespaceVariable",
			Handler:       _DirektivFlow_GetNamespaceVariable_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetWorkflowVariable",
			Handler:       _DirektivFlow_GetWorkflowVariable_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetInstanceVariable",
			Handler:       _DirektivFlow_GetInstanceVariable_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetNamespaceVariable",
			Handler:       _DirektivFlow_SetNamespaceVariable_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SetWorkflowVariable",
			Handler:       _DirektivFlow_SetWorkflowVariable_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "SetInstanceVariable",
			Handler:       _DirektivFlow_SetInstanceVariable_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/flow/protocol.proto",
}

DirektivFlow_ServiceDesc is the grpc.ServiceDesc for DirektivFlow 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_flow_action_log_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_get_instance_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_get_namespace_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_get_workflow_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_protocol_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_report_action_results_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_resume_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_set_instance_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_set_namespace_variable_proto protoreflect.FileDescriptor
View Source 
var File_pkg_flow_set_workflow_variable_proto protoreflect.FileDescriptor

Functions

func RegisterDirektivFlowServer 

func RegisterDirektivFlowServer(s grpc.ServiceRegistrar, srv DirektivFlowServer)

Types

type ActionLogRequest added in v0.3.3 

type ActionLogRequest struct {
	InstanceId *string  `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"`
	Msg        []string `protobuf:"bytes,2,rep,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ActionLogRequest.ProtoReflect.Descriptor instead.

func (*ActionLogRequest) GetInstanceId added in v0.3.3 

func (x *ActionLogRequest) GetInstanceId() string

func (*ActionLogRequest) GetMsg added in v0.3.3 

func (x *ActionLogRequest) GetMsg() []string

func (*ActionLogRequest) ProtoMessage added in v0.3.3 

func (*ActionLogRequest) ProtoMessage()

func (*ActionLogRequest) ProtoReflect added in v0.3.3 

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

func (*ActionLogRequest) Reset added in v0.3.3 

func (x *ActionLogRequest) Reset()

func (*ActionLogRequest) String added in v0.3.3 

func (x *ActionLogRequest) String() string

type DirektivFlowClient 

type DirektivFlowClient interface {
	ReportActionResults(ctx context.Context, in *ReportActionResultsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Resume(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetNamespaceVariable(ctx context.Context, in *GetNamespaceVariableRequest, opts ...grpc.CallOption) (DirektivFlow_GetNamespaceVariableClient, error)
	GetWorkflowVariable(ctx context.Context, in *GetWorkflowVariableRequest, opts ...grpc.CallOption) (DirektivFlow_GetWorkflowVariableClient, error)
	GetInstanceVariable(ctx context.Context, in *GetInstanceVariableRequest, opts ...grpc.CallOption) (DirektivFlow_GetInstanceVariableClient, error)
	SetNamespaceVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivFlow_SetNamespaceVariableClient, error)
	SetWorkflowVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivFlow_SetWorkflowVariableClient, error)
	SetInstanceVariable(ctx context.Context, opts ...grpc.CallOption) (DirektivFlow_SetInstanceVariableClient, error)
	ActionLog(ctx context.Context, in *ActionLogRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DirektivFlowClient is the client API for DirektivFlow service.

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

func NewDirektivFlowClient 

func NewDirektivFlowClient(cc grpc.ClientConnInterface) DirektivFlowClient

type DirektivFlowServer 

type DirektivFlowServer interface {
	ReportActionResults(context.Context, *ReportActionResultsRequest) (*empty.Empty, error)
	Resume(context.Context, *ResumeRequest) (*empty.Empty, error)
	GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivFlow_GetNamespaceVariableServer) error
	GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivFlow_GetWorkflowVariableServer) error
	GetInstanceVariable(*GetInstanceVariableRequest, DirektivFlow_GetInstanceVariableServer) error
	SetNamespaceVariable(DirektivFlow_SetNamespaceVariableServer) error
	SetWorkflowVariable(DirektivFlow_SetWorkflowVariableServer) error
	SetInstanceVariable(DirektivFlow_SetInstanceVariableServer) error
	ActionLog(context.Context, *ActionLogRequest) (*empty.Empty, error)
	// contains filtered or unexported methods
}

DirektivFlowServer is the server API for DirektivFlow service. All implementations must embed UnimplementedDirektivFlowServer for forward compatibility

type DirektivFlow_GetInstanceVariableClient added in v0.2.3 

type DirektivFlow_GetInstanceVariableClient interface {
	Recv() (*GetInstanceVariableResponse, error)
	grpc.ClientStream
}

type DirektivFlow_GetInstanceVariableServer added in v0.2.3 

type DirektivFlow_GetInstanceVariableServer interface {
	Send(*GetInstanceVariableResponse) error
	grpc.ServerStream
}

type DirektivFlow_GetNamespaceVariableClient added in v0.2.3 

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

type DirektivFlow_GetNamespaceVariableServer added in v0.2.3 

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

type DirektivFlow_GetWorkflowVariableClient added in v0.2.3 

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

type DirektivFlow_GetWorkflowVariableServer added in v0.2.3 

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

type DirektivFlow_SetInstanceVariableClient added in v0.2.3 

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

type DirektivFlow_SetInstanceVariableServer added in v0.2.3 

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

type DirektivFlow_SetNamespaceVariableClient added in v0.2.3 

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

type DirektivFlow_SetNamespaceVariableServer added in v0.2.3 

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

type DirektivFlow_SetWorkflowVariableClient added in v0.2.3 

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

type DirektivFlow_SetWorkflowVariableServer added in v0.2.3 

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

type GetInstanceVariableRequest added in v0.2.3 

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

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

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

Deprecated: Use GetInstanceVariableRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceVariableRequest) GetInstanceId added in v0.2.3 

func (x *GetInstanceVariableRequest) GetInstanceId() string

func (*GetInstanceVariableRequest) GetKey added in v0.2.3 

func (x *GetInstanceVariableRequest) GetKey() string

func (*GetInstanceVariableRequest) ProtoMessage added in v0.2.3 

func (*GetInstanceVariableRequest) ProtoMessage()

func (*GetInstanceVariableRequest) ProtoReflect added in v0.2.3 

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

func (*GetInstanceVariableRequest) Reset added in v0.2.3 

func (x *GetInstanceVariableRequest) Reset()

func (*GetInstanceVariableRequest) String added in v0.2.3 

func (x *GetInstanceVariableRequest) String() string

type GetInstanceVariableResponse added in v0.2.3 

type GetInstanceVariableResponse 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 (*GetInstanceVariableResponse) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use GetInstanceVariableResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceVariableResponse) GetChunkSize added in v0.2.3 

func (x *GetInstanceVariableResponse) GetChunkSize() int64

func (*GetInstanceVariableResponse) GetTotalSize added in v0.2.3 

func (x *GetInstanceVariableResponse) GetTotalSize() int64

func (*GetInstanceVariableResponse) GetValue added in v0.2.3 

func (x *GetInstanceVariableResponse) GetValue() []byte

func (*GetInstanceVariableResponse) ProtoMessage added in v0.2.3 

func (*GetInstanceVariableResponse) ProtoMessage()

func (*GetInstanceVariableResponse) ProtoReflect added in v0.2.3 

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

func (*GetInstanceVariableResponse) Reset added in v0.2.3 

func (x *GetInstanceVariableResponse) Reset()

func (*GetInstanceVariableResponse) String added in v0.2.3 

func (x *GetInstanceVariableResponse) String() string

type GetNamespaceVariableRequest added in v0.2.3 

type GetNamespaceVariableRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,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) GetInstanceId added in v0.2.3 

func (x *GetNamespaceVariableRequest) GetInstanceId() string

func (*GetNamespaceVariableRequest) GetKey added in v0.2.3 

func (x *GetNamespaceVariableRequest) GetKey() string

func (*GetNamespaceVariableRequest) ProtoMessage added in v0.2.3 

func (*GetNamespaceVariableRequest) ProtoMessage()

func (*GetNamespaceVariableRequest) ProtoReflect added in v0.2.3 

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

func (*GetNamespaceVariableRequest) Reset added in v0.2.3 

func (x *GetNamespaceVariableRequest) Reset()

func (*GetNamespaceVariableRequest) String added in v0.2.3 

func (x *GetNamespaceVariableRequest) String() string

type GetNamespaceVariableResponse added in v0.2.3 

type GetNamespaceVariableResponse struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
	TotalSize *int64 `protobuf:"varint,2,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"`
	ChunkSize *int64 `protobuf:"varint,3,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use GetNamespaceVariableResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceVariableResponse) GetChunkSize added in v0.2.3 

func (x *GetNamespaceVariableResponse) GetChunkSize() int64

func (*GetNamespaceVariableResponse) GetTotalSize added in v0.2.3 

func (x *GetNamespaceVariableResponse) GetTotalSize() int64

func (*GetNamespaceVariableResponse) GetValue added in v0.2.3 

func (x *GetNamespaceVariableResponse) GetValue() []byte

func (*GetNamespaceVariableResponse) ProtoMessage added in v0.2.3 

func (*GetNamespaceVariableResponse) ProtoMessage()

func (*GetNamespaceVariableResponse) ProtoReflect added in v0.2.3 

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

func (*GetNamespaceVariableResponse) Reset added in v0.2.3 

func (x *GetNamespaceVariableResponse) Reset()

func (*GetNamespaceVariableResponse) String added in v0.2.3 

func (x *GetNamespaceVariableResponse) String() string

type GetWorkflowVariableRequest added in v0.2.3 

type GetWorkflowVariableRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,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) GetInstanceId added in v0.2.3 

func (x *GetWorkflowVariableRequest) GetInstanceId() string

func (*GetWorkflowVariableRequest) GetKey added in v0.2.3 

func (x *GetWorkflowVariableRequest) GetKey() string

func (*GetWorkflowVariableRequest) ProtoMessage added in v0.2.3 

func (*GetWorkflowVariableRequest) ProtoMessage()

func (*GetWorkflowVariableRequest) ProtoReflect added in v0.2.3 

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

func (*GetWorkflowVariableRequest) Reset added in v0.2.3 

func (x *GetWorkflowVariableRequest) Reset()

func (*GetWorkflowVariableRequest) String added in v0.2.3 

func (x *GetWorkflowVariableRequest) String() string

type GetWorkflowVariableResponse added in v0.2.3 

type GetWorkflowVariableResponse struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
	TotalSize *int64 `protobuf:"varint,2,opt,name=totalSize,proto3,oneof" json:"totalSize,omitempty"`
	ChunkSize *int64 `protobuf:"varint,3,opt,name=chunkSize,proto3,oneof" json:"chunkSize,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use GetWorkflowVariableResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowVariableResponse) GetChunkSize added in v0.2.3 

func (x *GetWorkflowVariableResponse) GetChunkSize() int64

func (*GetWorkflowVariableResponse) GetTotalSize added in v0.2.3 

func (x *GetWorkflowVariableResponse) GetTotalSize() int64

func (*GetWorkflowVariableResponse) GetValue added in v0.2.3 

func (x *GetWorkflowVariableResponse) GetValue() []byte

func (*GetWorkflowVariableResponse) ProtoMessage added in v0.2.3 

func (*GetWorkflowVariableResponse) ProtoMessage()

func (*GetWorkflowVariableResponse) ProtoReflect added in v0.2.3 

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

func (*GetWorkflowVariableResponse) Reset added in v0.2.3 

func (x *GetWorkflowVariableResponse) Reset()

func (*GetWorkflowVariableResponse) String added in v0.2.3 

func (x *GetWorkflowVariableResponse) String() string

type ReportActionResultsRequest 

type ReportActionResultsRequest struct {
	InstanceId   *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,omitempty"`
	Step         *int32  `protobuf:"varint,2,opt,name=step,proto3,oneof" json:"step,omitempty"`
	ActionId     *string `protobuf:"bytes,3,opt,name=actionId,proto3,oneof" json:"actionId,omitempty"`
	ErrorCode    *string `protobuf:"bytes,4,opt,name=errorCode,proto3,oneof" json:"errorCode,omitempty"`
	ErrorMessage *string `protobuf:"bytes,5,opt,name=errorMessage,proto3,oneof" json:"errorMessage,omitempty"`
	Output       []byte  `protobuf:"bytes,6,opt,name=output,proto3,oneof" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportActionResultsRequest) Descriptor deprecated 

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

Deprecated: Use ReportActionResultsRequest.ProtoReflect.Descriptor instead.

func (*ReportActionResultsRequest) GetActionId 

func (x *ReportActionResultsRequest) GetActionId() string

func (*ReportActionResultsRequest) GetErrorCode 

func (x *ReportActionResultsRequest) GetErrorCode() string

func (*ReportActionResultsRequest) GetErrorMessage 

func (x *ReportActionResultsRequest) GetErrorMessage() string

func (*ReportActionResultsRequest) GetInstanceId 

func (x *ReportActionResultsRequest) GetInstanceId() string

func (*ReportActionResultsRequest) GetOutput 

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

func (*ReportActionResultsRequest) GetStep 

func (x *ReportActionResultsRequest) GetStep() int32

func (*ReportActionResultsRequest) ProtoMessage 

func (*ReportActionResultsRequest) ProtoMessage()

func (*ReportActionResultsRequest) ProtoReflect 

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

func (*ReportActionResultsRequest) Reset 

func (x *ReportActionResultsRequest) Reset()

func (*ReportActionResultsRequest) String 

func (x *ReportActionResultsRequest) String() string

type ResumeRequest 

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

func (*ResumeRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId 

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetStep 

func (x *ResumeRequest) GetStep() int32

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect 

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

func (*ResumeRequest) Reset 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (x *ResumeRequest) String() string

type SetInstanceVariableRequest added in v0.2.3 

type SetInstanceVariableRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,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 (*SetInstanceVariableRequest) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use SetInstanceVariableRequest.ProtoReflect.Descriptor instead.

func (*SetInstanceVariableRequest) GetChunkSize added in v0.2.3 

func (x *SetInstanceVariableRequest) GetChunkSize() int64

func (*SetInstanceVariableRequest) GetInstanceId added in v0.2.3 

func (x *SetInstanceVariableRequest) GetInstanceId() string

func (*SetInstanceVariableRequest) GetKey added in v0.2.3 

func (x *SetInstanceVariableRequest) GetKey() string

func (*SetInstanceVariableRequest) GetTotalSize added in v0.2.3 

func (x *SetInstanceVariableRequest) GetTotalSize() int64

func (*SetInstanceVariableRequest) GetValue added in v0.2.3 

func (x *SetInstanceVariableRequest) GetValue() []byte

func (*SetInstanceVariableRequest) ProtoMessage added in v0.2.3 

func (*SetInstanceVariableRequest) ProtoMessage()

func (*SetInstanceVariableRequest) ProtoReflect added in v0.2.3 

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

func (*SetInstanceVariableRequest) Reset added in v0.2.3 

func (x *SetInstanceVariableRequest) Reset()

func (*SetInstanceVariableRequest) String added in v0.2.3 

func (x *SetInstanceVariableRequest) String() string

type SetNamespaceVariableRequest added in v0.2.3 

type SetNamespaceVariableRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,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) GetInstanceId added in v0.2.3 

func (x *SetNamespaceVariableRequest) GetInstanceId() string

func (*SetNamespaceVariableRequest) GetKey added in v0.2.3 

func (x *SetNamespaceVariableRequest) GetKey() string

func (*SetNamespaceVariableRequest) GetTotalSize added in v0.2.3 

func (x *SetNamespaceVariableRequest) GetTotalSize() int64

func (*SetNamespaceVariableRequest) GetValue added in v0.2.3 

func (x *SetNamespaceVariableRequest) GetValue() []byte

func (*SetNamespaceVariableRequest) ProtoMessage added in v0.2.3 

func (*SetNamespaceVariableRequest) ProtoMessage()

func (*SetNamespaceVariableRequest) ProtoReflect added in v0.2.3 

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

func (*SetNamespaceVariableRequest) Reset added in v0.2.3 

func (x *SetNamespaceVariableRequest) Reset()

func (*SetNamespaceVariableRequest) String added in v0.2.3 

func (x *SetNamespaceVariableRequest) String() string

type SetWorkflowVariableRequest added in v0.2.3 

type SetWorkflowVariableRequest struct {
	InstanceId *string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof" json:"instanceId,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) GetInstanceId added in v0.2.3 

func (x *SetWorkflowVariableRequest) GetInstanceId() string

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

func (*SetWorkflowVariableRequest) ProtoMessage()

func (*SetWorkflowVariableRequest) ProtoReflect added in v0.2.3 

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

func (*SetWorkflowVariableRequest) Reset added in v0.2.3 

func (x *SetWorkflowVariableRequest) Reset()

func (*SetWorkflowVariableRequest) String added in v0.2.3 

func (x *SetWorkflowVariableRequest) String() string

type UnimplementedDirektivFlowServer 

type UnimplementedDirektivFlowServer struct {
}

UnimplementedDirektivFlowServer must be embedded to have forward compatible implementations.

func (UnimplementedDirektivFlowServer) ActionLog added in v0.3.3 

func (UnimplementedDirektivFlowServer) ActionLog(context.Context, *ActionLogRequest) (*empty.Empty, error)

func (UnimplementedDirektivFlowServer) GetInstanceVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) GetInstanceVariable(*GetInstanceVariableRequest, DirektivFlow_GetInstanceVariableServer) error

func (UnimplementedDirektivFlowServer) GetNamespaceVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) GetNamespaceVariable(*GetNamespaceVariableRequest, DirektivFlow_GetNamespaceVariableServer) error

func (UnimplementedDirektivFlowServer) GetWorkflowVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) GetWorkflowVariable(*GetWorkflowVariableRequest, DirektivFlow_GetWorkflowVariableServer) error

func (UnimplementedDirektivFlowServer) ReportActionResults 

func (UnimplementedDirektivFlowServer) ReportActionResults(context.Context, *ReportActionResultsRequest) (*empty.Empty, error)

func (UnimplementedDirektivFlowServer) Resume 

func (UnimplementedDirektivFlowServer) Resume(context.Context, *ResumeRequest) (*empty.Empty, error)

func (UnimplementedDirektivFlowServer) SetInstanceVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) SetInstanceVariable(DirektivFlow_SetInstanceVariableServer) error

func (UnimplementedDirektivFlowServer) SetNamespaceVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) SetNamespaceVariable(DirektivFlow_SetNamespaceVariableServer) error

func (UnimplementedDirektivFlowServer) SetWorkflowVariable added in v0.2.3 

func (UnimplementedDirektivFlowServer) SetWorkflowVariable(DirektivFlow_SetWorkflowVariableServer) error

type UnsafeDirektivFlowServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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