rpc

type InvokeActionRequest ¶

type InvokeActionRequest struct {
	ActionName     string                 `protobuf:"bytes,1,opt,name=action_name" json:"action_name,omitempty"`
	IdempotencyKey string                 `protobuf:"bytes,2,opt,name=idempotency_key" json:"idempotency_key,omitempty"`
	Args           []*autoflow.Value      `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Kwargs         []*autoflow.NamedValue `protobuf:"bytes,4,rep,name=kwargs" json:"kwargs,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *InvokeActionRequest) GetActionName() string

func (x *InvokeActionRequest) GetArgs() []*autoflow.Value

func (x *InvokeActionRequest) GetIdempotencyKey() string

func (x *InvokeActionRequest) GetKwargs() []*autoflow.NamedValue

func (*InvokeActionRequest) ProtoMessage()

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

func (x *InvokeActionRequest) Reset()

func (x *InvokeActionRequest) String() string

type InvokeActionResponse ¶

type InvokeActionResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*InvokeActionResponse_Result
	//	*InvokeActionResponse_Error
	Response isInvokeActionResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

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

func (x *InvokeActionResponse) GetError() string

func (x *InvokeActionResponse) GetResponse() isInvokeActionResponse_Response

func (x *InvokeActionResponse) GetResult() *autoflow.Value

func (*InvokeActionResponse) ProtoMessage()

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

func (x *InvokeActionResponse) Reset()

func (x *InvokeActionResponse) String() string

type InvokeActionResponse_Error ¶

type InvokeActionResponse_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,oneof"`
}

type InvokeActionResponse_Result ¶

type InvokeActionResponse_Result struct {
	Result *autoflow.Value `protobuf:"bytes,1,opt,name=result,oneof"`
}

type ModuleAPIClient ¶

type ModuleAPIClient interface {
	InvokeAction(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[InvokeActionResponse, InvokeActionRequest], error)
}

ModuleAPIClient is the client API for ModuleAPI 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 NewModuleAPIClient(cc grpc.ClientConnInterface) ModuleAPIClient

type ModuleAPIServer ¶

type ModuleAPIServer interface {
	InvokeAction(grpc.BidiStreamingServer[InvokeActionResponse, InvokeActionRequest]) error
	// contains filtered or unexported methods
}

ModuleAPIServer is the server API for ModuleAPI service. All implementations must embed UnimplementedModuleAPIServer for forward compatibility.

type ModuleAPI_InvokeActionClient ¶

type ModuleAPI_InvokeActionClient = grpc.BidiStreamingClient[InvokeActionResponse, InvokeActionRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ModuleAPI_InvokeActionServer ¶

type ModuleAPI_InvokeActionServer = grpc.BidiStreamingServer[InvokeActionResponse, InvokeActionRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ModuleRegistryClient ¶

type ModuleRegistryClient interface {
	RegisterDescriptor(ctx context.Context, in *RegisterDescriptorRequest, opts ...grpc.CallOption) (*RegisterDescriptorResponse, error)
}

ModuleRegistryClient is the client API for ModuleRegistry 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 NewModuleRegistryClient(cc grpc.ClientConnInterface) ModuleRegistryClient

type ModuleRegistryServer ¶

type ModuleRegistryServer interface {
	RegisterDescriptor(context.Context, *RegisterDescriptorRequest) (*RegisterDescriptorResponse, error)
	// contains filtered or unexported methods
}

ModuleRegistryServer is the server API for ModuleRegistry service. All implementations must embed UnimplementedModuleRegistryServer for forward compatibility.

type RegisterDescriptorRequest ¶

type RegisterDescriptorRequest struct {
	ModuleDesc *autoflow.ModuleDescriptor `protobuf:"bytes,1,opt,name=module_desc,json=moduleDesc" json:"module_desc,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *RegisterDescriptorRequest) GetModuleDesc() *autoflow.ModuleDescriptor

func (*RegisterDescriptorRequest) ProtoMessage()

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

func (x *RegisterDescriptorRequest) Reset()

func (x *RegisterDescriptorRequest) String() string

type RegisterDescriptorResponse ¶

type RegisterDescriptorResponse struct {
	// contains filtered or unexported fields
}

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

func (*RegisterDescriptorResponse) ProtoMessage()

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

func (x *RegisterDescriptorResponse) Reset()

func (x *RegisterDescriptorResponse) String() string

type UnimplementedModuleAPIServer ¶

type UnimplementedModuleAPIServer struct{}

UnimplementedModuleAPIServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedModuleAPIServer) InvokeAction(grpc.BidiStreamingServer[InvokeActionResponse, InvokeActionRequest]) error

type UnimplementedModuleRegistryServer ¶

type UnimplementedModuleRegistryServer struct{}

UnimplementedModuleRegistryServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedModuleRegistryServer) RegisterDescriptor(context.Context, *RegisterDescriptorRequest) (*RegisterDescriptorResponse, error)

type UnsafeModuleAPIServer ¶

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

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

type UnsafeModuleRegistryServer ¶

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

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