server

Documentation

Index

• Variables
• type PileServer
  • func NewWithRunner(runner Runner) *PileServer
  • func (p *PileServer) Serve(ctx context.Context, l net.Listener, authConfig auth.Config) error
• type Runner

Variables

var NotAuthorizedError = fmt.Errorf("not authorized")

Types

type PileServer

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

func NewWithRunner

func NewWithRunner(runner Runner) *PileServer

func (*PileServer) Serve

func (p *PileServer) Serve(ctx context.Context, l net.Listener, authConfig auth.Config) error

Serve makes the server implementation available on a given listener

type Runner

type Runner interface {
	Start(config runner.Config) (name string, err error)
	Stop(name string) (*runner.Status, error)
	Status(name string) (*runner.Status, error)
	Output(name string) (output <-chan []byte, cancel func(), err error)
}