executor

Documentation

Index

• Variables
• func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)
• type ExecutorClient
  • func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient
• type ExecutorServer
• type Executor_ExecuteBatchClient
• type Executor_ExecuteBatchServer
• type UnimplementedExecutorServer
  • func (UnimplementedExecutorServer) Execute(context.Context, *message.Task) (*message.Task, error)
  • func (UnimplementedExecutorServer) ExecuteAsync(context.Context, *message.Task) (*message.Task, error)
  • func (UnimplementedExecutorServer) ExecuteBatch(*message.Tasks, Executor_ExecuteBatchServer) error
  • func (UnimplementedExecutorServer) ExecuteBatchAsync(context.Context, *message.Tasks) (*message.Task, error)
  • func (UnimplementedExecutorServer) LoadReport(context.Context, *message.Filter) (*message.Tasks, error)
• type UnsafeExecutorServer

Variables

var Executor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Executor",
	HandlerType: (*ExecutorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Execute",
			Handler:    _Executor_Execute_Handler,
		},
		{
			MethodName: "ExecuteAsync",
			Handler:    _Executor_ExecuteAsync_Handler,
		},
		{
			MethodName: "ExecuteBatchAsync",
			Handler:    _Executor_ExecuteBatchAsync_Handler,
		},
		{
			MethodName: "LoadReport",
			Handler:    _Executor_LoadReport_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteBatch",
			Handler:       _Executor_ExecuteBatch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "executor.proto",
}

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

var File_executor_proto protoreflect.FileDescriptor

Functions

func RegisterExecutorServer

func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)

Types

type ExecutorClient

type ExecutorClient interface {
	Execute(ctx context.Context, in *message.Task, opts ...grpc.CallOption) (*message.Task, error)
	ExecuteBatch(ctx context.Context, in *message.Tasks, opts ...grpc.CallOption) (Executor_ExecuteBatchClient, error)
	ExecuteAsync(ctx context.Context, in *message.Task, opts ...grpc.CallOption) (*message.Task, error)
	ExecuteBatchAsync(ctx context.Context, in *message.Tasks, opts ...grpc.CallOption) (*message.Task, error)
	LoadReport(ctx context.Context, in *message.Filter, opts ...grpc.CallOption) (*message.Tasks, error)
}

ExecutorClient is the client API for Executor 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 NewExecutorClient

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorServer

type ExecutorServer interface {
	Execute(context.Context, *message.Task) (*message.Task, error)
	ExecuteBatch(*message.Tasks, Executor_ExecuteBatchServer) error
	ExecuteAsync(context.Context, *message.Task) (*message.Task, error)
	ExecuteBatchAsync(context.Context, *message.Tasks) (*message.Task, error)
	LoadReport(context.Context, *message.Filter) (*message.Tasks, error)
	// contains filtered or unexported methods
}

ExecutorServer is the server API for Executor service. All implementations must embed UnimplementedExecutorServer for forward compatibility

type Executor_ExecuteBatchClient

type Executor_ExecuteBatchClient interface {
	Recv() (*message.Task, error)
	grpc.ClientStream
}

type Executor_ExecuteBatchServer

type Executor_ExecuteBatchServer interface {
	Send(*message.Task) error
	grpc.ServerStream
}

type UnimplementedExecutorServer

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServer) Execute

func (UnimplementedExecutorServer) Execute(context.Context, *message.Task) (*message.Task, error)

func (UnimplementedExecutorServer) ExecuteAsync

func (UnimplementedExecutorServer) ExecuteAsync(context.Context, *message.Task) (*message.Task, error)

func (UnimplementedExecutorServer) ExecuteBatch

func (UnimplementedExecutorServer) ExecuteBatch(*message.Tasks, Executor_ExecuteBatchServer) error

func (UnimplementedExecutorServer) ExecuteBatchAsync

func (UnimplementedExecutorServer) ExecuteBatchAsync(context.Context, *message.Tasks) (*message.Task, error)

func (UnimplementedExecutorServer) LoadReport

func (UnimplementedExecutorServer) LoadReport(context.Context, *message.Filter) (*message.Tasks, error)

type UnsafeExecutorServer

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

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