function

Documentation

Index

• Variables
• type FunctionService
  • func NewRuncFunctionService(ctx context.Context, opts FunctionServiceOpts) (FunctionService, error)
• type FunctionServiceOpts
• type FunctionTask
  • func (t *FunctionTask) Cancel(ctx context.Context, reason types.TaskCancellationReason) error
  • func (t *FunctionTask) Execute(ctx context.Context, options ...interface{}) error
  • func (t *FunctionTask) HeartBeat(ctx context.Context) (bool, error)
  • func (t *FunctionTask) Metadata() types.TaskMetadata
  • func (t *FunctionTask) Retry(ctx context.Context) error
• type RunCFunctionService
  • func (fs *RunCFunctionService) FunctionGetArgs(ctx context.Context, in *pb.FunctionGetArgsRequest) (*pb.FunctionGetArgsResponse, error)
  • func (fs *RunCFunctionService) FunctionInvoke(in *pb.FunctionInvokeRequest, stream pb.FunctionService_FunctionInvokeServer) error
  • func (fs *RunCFunctionService) FunctionMonitor(req *pb.FunctionMonitorRequest, ...) error
  • func (fs *RunCFunctionService) FunctionSetResult(ctx context.Context, in *pb.FunctionSetResultRequest) (*pb.FunctionSetResultResponse, error)

Variables

var Keys = &keys{}

Types

type FunctionService

type FunctionService interface {
	pb.FunctionServiceServer
	FunctionInvoke(in *pb.FunctionInvokeRequest, stream pb.FunctionService_FunctionInvokeServer) error
	FunctionGetArgs(ctx context.Context, in *pb.FunctionGetArgsRequest) (*pb.FunctionGetArgsResponse, error)
	FunctionSetResult(ctx context.Context, in *pb.FunctionSetResultRequest) (*pb.FunctionSetResultResponse, error)
}

func NewRuncFunctionService

func NewRuncFunctionService(ctx context.Context,
	opts FunctionServiceOpts,
) (FunctionService, error)

type FunctionServiceOpts

type FunctionServiceOpts struct {
	Config         types.AppConfig
	RedisClient    *common.RedisClient
	BackendRepo    repository.BackendRepository
	TaskRepo       repository.TaskRepository
	ContainerRepo  repository.ContainerRepository
	Scheduler      *scheduler.Scheduler
	Tailscale      *network.Tailscale
	RouteGroup     *echo.Group
	TaskDispatcher *task.Dispatcher
}

type FunctionTask

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

func (*FunctionTask) Cancel

func (t *FunctionTask) Cancel(ctx context.Context, reason types.TaskCancellationReason) error

func (*FunctionTask) Execute

func (t *FunctionTask) Execute(ctx context.Context, options ...interface{}) error

func (*FunctionTask) HeartBeat

func (t *FunctionTask) HeartBeat(ctx context.Context) (bool, error)

func (*FunctionTask) Metadata

func (t *FunctionTask) Metadata() types.TaskMetadata

func (*FunctionTask) Retry

func (t *FunctionTask) Retry(ctx context.Context) error

type RunCFunctionService

type RunCFunctionService struct {
	pb.UnimplementedFunctionServiceServer
	// contains filtered or unexported fields
}

func (*RunCFunctionService) FunctionGetArgs

func (fs *RunCFunctionService) FunctionGetArgs(ctx context.Context, in *pb.FunctionGetArgsRequest) (*pb.FunctionGetArgsResponse, error)

func (*RunCFunctionService) FunctionInvoke

func (fs *RunCFunctionService) FunctionInvoke(in *pb.FunctionInvokeRequest, stream pb.FunctionService_FunctionInvokeServer) error

func (*RunCFunctionService) FunctionMonitor

func (fs *RunCFunctionService) FunctionMonitor(req *pb.FunctionMonitorRequest, stream pb.FunctionService_FunctionMonitorServer) error

func (*RunCFunctionService) FunctionSetResult

func (fs *RunCFunctionService) FunctionSetResult(ctx context.Context, in *pb.FunctionSetResultRequest) (*pb.FunctionSetResultResponse, error)