mock

Documentation

Index

• type Starfish
  • func (s *Starfish) AddJob(t *testing.T, peerC peer.Node, job *patrick.Job) error
  • func (s *Starfish) Cancel(jid string, cid_log map[string]string) (interface{}, error)
  • func (s *Starfish) Close()
  • func (s *Starfish) DatabaseStats() (kvdbIface.Stats, error)
  • func (s *Starfish) Done(jid string, cid_log map[string]string, assetCid map[string]string) error
  • func (s *Starfish) Failed(jid string, cid_log map[string]string, assetCid map[string]string) error
  • func (s *Starfish) Get(jid string) (*patrick.Job, error)
  • func (s *Starfish) IsLocked(jid string) (bool, error)
  • func (s *Starfish) List() ([]string, error)
  • func (s *Starfish) Lock(jid string, eta uint32) error
  • func (s *Starfish) Peers(...peerCore.ID) patrick.Client
  • func (s *Starfish) Timeout(jid string) error
  • func (s *Starfish) Unlock(jid string) error

Types

type Starfish

type Starfish struct {
	Jobs map[string]*patrick.Job
}

func (*Starfish) AddJob

func (s *Starfish) AddJob(t *testing.T, peerC peer.Node, job *patrick.Job) error

func (*Starfish) Cancel

func (s *Starfish) Cancel(jid string, cid_log map[string]string) (interface{}, error)

added to satisfy the patrick interface

func (*Starfish) Close

func (s *Starfish) Close()

func (*Starfish) DatabaseStats

func (s *Starfish) DatabaseStats() (kvdbIface.Stats, error)

func (*Starfish) Done

func (s *Starfish) Done(jid string, cid_log map[string]string, assetCid map[string]string) error

func (*Starfish) Failed

func (s *Starfish) Failed(jid string, cid_log map[string]string, assetCid map[string]string) error

func (*Starfish) Get

func (s *Starfish) Get(jid string) (*patrick.Job, error)

added to satisfy the patrick interface

func (*Starfish) IsLocked

func (s *Starfish) IsLocked(jid string) (bool, error)

func (*Starfish) List

func (s *Starfish) List() ([]string, error)

added to satisfy the patrick interface

func (*Starfish) Lock

func (s *Starfish) Lock(jid string, eta uint32) error

func (*Starfish) Peers

func (s *Starfish) Peers(...peerCore.ID) patrick.Client

func (*Starfish) Timeout

func (s *Starfish) Timeout(jid string) error

added to satisfy the patrick interface

func (*Starfish) Unlock

func (s *Starfish) Unlock(jid string) error

added to satisfy the patrick interface