satellite

Documentation

Index

• Constants
• Variables
• func Decrypt(content string, orig []byte) (string, error)
• func GenKey() (orig []byte, cipher string)
• func InitPubkey()
• func NakedEncrypt(content string, orig []byte) (string, error)
• func StandardSatellite(root string, delay time.Duration)
• type PostOffice
  • func NewPostOffice(root string, avaliableHandlers []string) *PostOffice
  • func (p *PostOffice) GetTask() (*Postman, error)
• type Postman
  • func (pm *Postman) SendResult(res *dispatcher.SubtaskResult) error

Constants

const (
	// AES-256
	KeyLength = 32
)

Variables

var (
	ErrNoNewTasks   = errors.New("no new tasks")
	ErrTaskVanished = errors.New("task vanished")
)

var (
	ErrNoPublicKeyFound = errors.New("no public key found")
)

var SilentSatellite = false

Functions

func Decrypt

func Decrypt(content string, orig []byte) (string, error)

func GenKey

func GenKey() (orig []byte, cipher string)

func InitPubkey

func InitPubkey()

This function could be called any times you want, explicitly or implicitly.

func NakedEncrypt

func NakedEncrypt(content string, orig []byte) (string, error)

func StandardSatellite

func StandardSatellite(root string, delay time.Duration)

Types

type PostOffice

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

func NewPostOffice

func NewPostOffice(root string, avaliableHandlers []string) *PostOffice

func (*PostOffice) GetTask

func (p *PostOffice) GetTask() (*Postman, error)

type Postman

type Postman struct {
	Subtask *dispatcher.Subtask
	// contains filtered or unexported fields
}

Handles a specific subtask

func (*Postman) SendResult

func (pm *Postman) SendResult(res *dispatcher.SubtaskResult) error