flow

Documentation

Index

• Variables
• func RegisterDirektivFlowServer(s grpc.ServiceRegistrar, srv DirektivFlowServer)
• type DirektivFlowClient
  • func NewDirektivFlowClient(cc grpc.ClientConnInterface) DirektivFlowClient
• type DirektivFlowServer
• type ReportActionResultsRequest
  • func (*ReportActionResultsRequest) Descriptor() ([]byte, []int)
  • func (x *ReportActionResultsRequest) GetActionId() string
  • func (x *ReportActionResultsRequest) GetErrorCode() string
  • func (x *ReportActionResultsRequest) GetErrorMessage() string
  • func (x *ReportActionResultsRequest) GetInstanceId() string
  • func (x *ReportActionResultsRequest) GetOutput() []byte
  • func (x *ReportActionResultsRequest) GetStep() int32
  • func (*ReportActionResultsRequest) ProtoMessage()
  • func (x *ReportActionResultsRequest) ProtoReflect() protoreflect.Message
  • func (x *ReportActionResultsRequest) Reset()
  • func (x *ReportActionResultsRequest) String() string
• type ResumeRequest
  • func (*ResumeRequest) Descriptor() ([]byte, []int)
  • func (x *ResumeRequest) GetInstanceId() string
  • func (x *ResumeRequest) GetStep() int32
  • func (*ResumeRequest) ProtoMessage()
  • func (x *ResumeRequest) ProtoReflect() protoreflect.Message
  • func (x *ResumeRequest) Reset()
  • func (x *ResumeRequest) String() string
• type UnimplementedDirektivFlowServer
  • func (UnimplementedDirektivFlowServer) ReportActionResults(context.Context, *ReportActionResultsRequest) (*empty.Empty, error)
  • func (UnimplementedDirektivFlowServer) Resume(context.Context, *ResumeRequest) (*empty.Empty, error)
• type UnsafeDirektivFlowServer

Variables

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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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)

var File_pkg_flow_protocol_proto protoreflect.FileDescriptor

var File_pkg_flow_report_action_results_proto protoreflect.FileDescriptor

var File_pkg_flow_resume_proto protoreflect.FileDescriptor

Functions

func RegisterDirektivFlowServer

func RegisterDirektivFlowServer(s grpc.ServiceRegistrar, srv DirektivFlowServer)

Types

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

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)
	// contains filtered or unexported methods
}

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

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

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

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 UnimplementedDirektivFlowServer

type UnimplementedDirektivFlowServer struct {
}

UnimplementedDirektivFlowServer must be embedded to have forward compatible implementations.

func (UnimplementedDirektivFlowServer) ReportActionResults

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

func (UnimplementedDirektivFlowServer) Resume

func (UnimplementedDirektivFlowServer) Resume(context.Context, *ResumeRequest) (*empty.Empty, 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.