server

Documentation

Index

• func NewDebugServer(env Env) debug.DebugServer
• func NewDumpFS(mountPath string) *dumpFS
• type DumpFS
• type Env
• type Worker
  • func NewWorker(env Env) *Worker
  • func (w *Worker) Run(ctx context.Context) error

Functions

func NewDebugServer

func NewDebugServer(env Env) debug.DebugServer

NewDebugServer creates a new server that serves the debug api over GRPC

func NewDumpFS

func NewDumpFS(mountPath string) *dumpFS

Types

type DumpFS

type DumpFS interface {
	Write(string, func(io.Writer) error) error
	WithPrefix(string) DumpFS
}

type Env

type Env struct {
	DB            *pachsql.DB
	SidecarClient *client.APIClient
	Name          string
	GetLokiClient func() (*loki.Client, error)
	GetKubeClient func() kubernetes.Interface
	Config        pachconfig.Configuration
	TaskService   task.Service

	GetPachClient func(context.Context) *client.APIClient
}

type Worker

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

func NewWorker

func NewWorker(env Env) *Worker

func (*Worker) Run

func (w *Worker) Run(ctx context.Context) error