output

Documentation

Index

• Variables
• func GetTaskOutputFiles(workspaceName string, task *types.TaskWithRelated) map[string]string
• func GetTaskOutputPath(workspaceName string, task *types.TaskWithRelated, outputId string, ...) string
• func GetTaskOutputRootPath(workspaceName string, task *types.TaskWithRelated) string
• func SetPublicURL(ctx context.Context, config types.AppConfig, ...) (string, error)
• type OutputRedisService
  • func (o *OutputRedisService) OutputPublicURL(ctx context.Context, in *pb.OutputPublicURLRequest) (*pb.OutputPublicURLResponse, error)
  • func (o *OutputRedisService) OutputSaveStream(stream pb.OutputService_OutputSaveStreamServer) error
  • func (o *OutputRedisService) OutputStat(ctx context.Context, in *pb.OutputStatRequest) (*pb.OutputStatResponse, error)
• type OutputSaveContent
• type OutputService
  • func NewOutputRedisService(config types.AppConfig, redisClient *common.RedisClient, ...) (OutputService, error)
• type Stat

Variables

var (
	Keys = &keys{}
)

Redis keys

Functions

func GetTaskOutputFiles

func GetTaskOutputFiles(workspaceName string, task *types.TaskWithRelated) map[string]string

func GetTaskOutputPath

func GetTaskOutputPath(workspaceName string, task *types.TaskWithRelated, outputId string, filename string) string

func GetTaskOutputRootPath

func GetTaskOutputRootPath(workspaceName string, task *types.TaskWithRelated) string

func SetPublicURL

func SetPublicURL(ctx context.Context, config types.AppConfig, backendRepo repository.BackendRepository, redisClient *common.RedisClient, workspaceName, taskId, outputId, filename string, expires uint32) (string, error)

Types

type OutputRedisService

type OutputRedisService struct {
	pb.UnimplementedOutputServiceServer
	// contains filtered or unexported fields
}

func (*OutputRedisService) OutputPublicURL

func (o *OutputRedisService) OutputPublicURL(ctx context.Context, in *pb.OutputPublicURLRequest) (*pb.OutputPublicURLResponse, error)

func (*OutputRedisService) OutputSaveStream

func (o *OutputRedisService) OutputSaveStream(stream pb.OutputService_OutputSaveStreamServer) error

func (*OutputRedisService) OutputStat

func (o *OutputRedisService) OutputStat(ctx context.Context, in *pb.OutputStatRequest) (*pb.OutputStatResponse, error)

type OutputSaveContent

type OutputSaveContent struct {
	Filename string
	TaskID   string
	Content  []byte
}

type OutputService

type OutputService interface {
	pb.OutputServiceServer
	OutputSaveStream(stream pb.OutputService_OutputSaveStreamServer) error
	OutputStat(ctx context.Context, in *pb.OutputStatRequest) (*pb.OutputStatResponse, error)
	OutputPublicURL(ctx context.Context, in *pb.OutputPublicURLRequest) (*pb.OutputPublicURLResponse, error)
}

func NewOutputRedisService

func NewOutputRedisService(config types.AppConfig, redisClient *common.RedisClient, backendRepo repository.BackendRepository, routeGroup *echo.Group) (OutputService, error)

type Stat

type Stat struct {
	Mode  string
	Size  int64
	Atime time.Time
	Mtime time.Time
}