server

Documentation

Index

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

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
	GetDynamicKubeClient func() dynamic.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 WorkerEnv) *Worker

func (*Worker) Run

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

type WorkerEnv

type WorkerEnv struct {
	PFS         pfs.APIClient
	TaskService task.Service
}