monkey

Documentation

Index

• Variables
• func Package() config.ProtoCommandIface
• type Config
• type Monkey
  • func (m *Monkey) Run()
  • func (m *Monkey) RunJob() (err error)
• type Service
  • func New(ctx context.Context, config *tauConfig.Node) (*Service, error)
  • func (srv *Service) Close() error
  • func (s *Service) Delete(jid string)
  • func (s *Service) Dev() bool
  • func (s *Service) Hoarder() hoarderIface.Client
  • func (s *Service) Node() peer.Node
  • func (s *Service) Patrick() patrick.Client
  • func (m *Service) ServiceHandler(ctx context.Context, conn streams.Connection, body command.Body) (cr.Response, error)

Variables

var (
	GetGitRepoMaxRetries      = 3
	GetGitRepoWaitBeforeRetry = 5 * time.Second
)

var NewPatrick = func(ctx context.Context, node peer.Node) (patrick.Client, error) {
	return patrickClient.New(ctx, node)
}

TODO: This sucks

This is a variable so that it can be overridden in tests

Functions

func Package

func Package() config.ProtoCommandIface

Types

type Config

type Config config.Node

type Monkey

type Monkey struct {
	Id      string
	Status  patrick.JobStatus
	LogCID  string
	Service *Service
	Job     *patrick.Job
	// contains filtered or unexported fields
}

func (*Monkey) Run

func (m *Monkey) Run()

func (*Monkey) RunJob

func (m *Monkey) RunJob() (err error)

type Service

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

func New

func New(ctx context.Context, config *tauConfig.Node) (*Service, error)

func (*Service) Close

func (srv *Service) Close() error

func (*Service) Delete

func (s *Service) Delete(jid string)

func (*Service) Dev

func (s *Service) Dev() bool

func (*Service) Hoarder

func (s *Service) Hoarder() hoarderIface.Client

func (*Service) Node

func (s *Service) Node() peer.Node

func (*Service) Patrick

func (s *Service) Patrick() patrick.Client

func (*Service) ServiceHandler

func (m *Service) ServiceHandler(ctx context.Context, conn streams.Connection, body command.Body) (cr.Response, error)