worker

Documentation

Overview

Simple in-memory worker & queue

Index

• Constants
• func CreateServerLog(serverRecord *models.Record, msgType string, message string, payload string) error
• func SaveServerLog(message ServerLog) error
• func SetApplication(application core.App)
• func StartWorker(application core.App)
• func SubmitAndForget(work Work)
• func SubmitAndWait(work Work)
• type AuthorizedKey
  • func (key AuthorizedKey) Serialize() string
• type ServerLog
  • func NewServerLog(serverId string, msgType string, message string, payload string) ServerLog
• type SyncServerWork
  • func (work *SyncServerWork) Execute() error
  • func (work *SyncServerWork) Name() string
• type Work

Constants

const AUTHORIZED_KEYS_END_MARKER = "# <=== ssh-authorized-manager END marker ==="

const AUTHORIZED_KEYS_START_MARKER = "# === ssh-authorized-manager START marker ===>"

Functions

func CreateServerLog

func CreateServerLog(serverRecord *models.Record, msgType string, message string, payload string) error

func SaveServerLog

func SaveServerLog(message ServerLog) error

func SetApplication

func SetApplication(application core.App)

func StartWorker

func StartWorker(application core.App)

func SubmitAndForget

func SubmitAndForget(work Work)

func SubmitAndWait

func SubmitAndWait(work Work)

Types

type AuthorizedKey

type AuthorizedKey struct {
	Options string
	Type    string
	Key     ssh.PublicKey
	Comment string
}

func (AuthorizedKey) Serialize

func (key AuthorizedKey) Serialize() string

type ServerLog

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

func NewServerLog

func NewServerLog(serverId string, msgType string, message string, payload string) ServerLog

type SyncServerWork

type SyncServerWork struct {
	Server *models.Record
}

func (*SyncServerWork) Execute

func (work *SyncServerWork) Execute() error

func (*SyncServerWork) Name

func (work *SyncServerWork) Name() string

type Work

type Work interface {
	Name() string
	Execute() error
}