service

Documentation

Index

• Variables
• func Package() config.ProtoCommandIface
• type Config
• type GitRepository
  • func (gr *GitRepository) Clone(ctx context.Context, path string, ref string) error
  • func (gr *GitRepository) Path() string
  • func (gr *GitRepository) Url() *string
• type Lock
• type PatrickService
  • func New(ctx context.Context, config *tauConfig.Node) (*PatrickService, error)
  • func (srv *PatrickService) Close() error
  • func (srv *PatrickService) GitHubTokenHTTPAuth(ctx http.Context) (interface{}, error)
  • func (srv *PatrickService) GitHubTokenHTTPAuthCleanup(ctx http.Context) (interface{}, error)
  • func (s *PatrickService) KV() kvdb.KVDB
  • func (srv *PatrickService) NewGitRepository(provider string, repositoryId string, output io.Writer) (iface.GitRepository, error)
  • func (s *PatrickService) Node() peer.Node
  • func (p *PatrickService) ReannounceFailedJobs(ctx context.Context) error
  • func (p *PatrickService) ReannounceJobs(ctx context.Context) error
  • func (srv *PatrickService) RegisterJob(ctx context.Context, newJob *patrick.Job) error

Variables

var (
	BootstrapTime = 10 * time.Second

	DefaultReAnnounceJobTime        = 5 * time.Minute
	DefaultReAnnounceFailedJobsTime = 5 * time.Minute
)

Functions

func Package

func Package() config.ProtoCommandIface

Types

type Config

type Config struct {
	config.Node `yaml:"z,omitempty"`
}

type GitRepository

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

func (*GitRepository) Clone

func (gr *GitRepository) Clone(ctx context.Context, path string, ref string) error

func (*GitRepository) Path

func (gr *GitRepository) Path() string

func (*GitRepository) Url

func (gr *GitRepository) Url() *string

type Lock

type Lock struct {
	Pid       libp2p.ID `cbor:"4,keyasint"`
	Timestamp int64     `cbor:"8,keyasint"`
	Eta       int64     `cbor:"16,keyasint"`
}

TODO: optimize cbor storage

type PatrickService

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

func New

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

func (*PatrickService) Close

func (srv *PatrickService) Close() error

func (*PatrickService) GitHubTokenHTTPAuth

func (srv *PatrickService) GitHubTokenHTTPAuth(ctx http.Context) (interface{}, error)

func (*PatrickService) GitHubTokenHTTPAuthCleanup

func (srv *PatrickService) GitHubTokenHTTPAuthCleanup(ctx http.Context) (interface{}, error)

func (*PatrickService) KV

func (s *PatrickService) KV() kvdb.KVDB

func (*PatrickService) NewGitRepository

func (srv *PatrickService) NewGitRepository(provider string, repositoryId string, output io.Writer) (iface.GitRepository, error)

func (*PatrickService) Node

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

func (*PatrickService) ReannounceFailedJobs

func (p *PatrickService) ReannounceFailedJobs(ctx context.Context) error

func (*PatrickService) ReannounceJobs

func (p *PatrickService) ReannounceJobs(ctx context.Context) error

func (*PatrickService) RegisterJob

func (srv *PatrickService) RegisterJob(ctx context.Context, newJob *patrick.Job) error