events

package
v0.0.0-...-e168591 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2017 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NONE int = iota
	WARNING
	NORMAL
	DEBUG
)

Variables

View Source
var EventMap = map[string]Event{
	"pull":   Pull,
	"push":   Push,
	"sh":     Sh,
	"rsync":  Rsync,
	"import": Import,
}

Functions

func Check

func Check(chSync chan CheckEntry, ce CheckEntry)

func Cmd

func Cmd(action string, se interface{}, command string, retry bool) (string, error)

func Debug

func Debug(se interface{}, msg ...interface{})

func FormatFileName

func FormatFileName(name string) string

func Import

func Import(ee EventEntry)

func Listen

func Listen()

func Normal

func Normal(se interface{}, msg ...interface{})

func Pull

func Pull(ee EventEntry)

func Push

func Push(ee EventEntry)

func Recv

func Recv(timeout time.Duration) (err error)

func Rsync

func Rsync(ee EventEntry)

func Send

func Send(ee EventEntry)

func Sh

func Sh(ee EventEntry)

func Warning

func Warning(se interface{}, msg ...interface{})

func Watch

func Watch(chSync chan CheckEntry, timeout time.Duration)

Types

type CheckEntry

type CheckEntry struct {
	Conf    string
	Supname string
}

type Cmdcli

type Cmdcli struct {
	Se        SyncEntry
	Condition string
	Code      string
	Path      string
	LocalPath string
	File      string
	LocalFile string
	SyncTime  string
}

func NewCmdcli

func NewCmdcli(se SyncEntry) *Cmdcli

func (*Cmdcli) Exec

func (cli *Cmdcli) Exec(method string) (out string, rterr error)

func (*Cmdcli) Import

func (cli *Cmdcli) Import() error

func (*Cmdcli) Sh

func (cli *Cmdcli) Sh() error

type Event

type Event func(EventEntry)

type EventEntry

type EventEntry struct {
	Name string
	Se   SyncEntry
}

type Ftpcli

type Ftpcli struct {
	Se        SyncEntry
	Host      string
	Port      string
	Username  string
	Passwd    string
	Path      string
	LocalPath string
	File      string
	LocalFile string
	Passive   bool
	SyncTime  string
	// contains filtered or unexported fields
}

func NewFtpcli

func NewFtpcli(se SyncEntry) *Ftpcli

func (*Ftpcli) Pull

func (cli *Ftpcli) Pull() (rterr error)

func (*Ftpcli) Push

func (cli *Ftpcli) Push() (rterr error)

type Logger

type Logger struct {
	Level         int
	Path          string
	NeedRsync     bool
	RsyncCD       int
	RsyncHost     string
	RsyncPort     string
	RsyncUsername string
	RsyncPasswd   string
	RsyncPath     string
	RsyncCode     string
	RsyncName     string
}
var DefLogger *Logger

func NewLogger

func NewLogger(cnf *config.Config) *Logger

func (Logger) Debug

func (l Logger) Debug(msg ...interface{})

func (Logger) Normal

func (l Logger) Normal(msg ...interface{})

func (Logger) ReadyRsync

func (l Logger) ReadyRsync(msg string, lvl int, seval interface{})

func (Logger) Rsync

func (l Logger) Rsync()

func (Logger) Warning

func (l Logger) Warning(msg ...interface{})

func (Logger) WriteFile

func (l Logger) WriteFile(filename string, data []byte) error

type RsyncEntry

type RsyncEntry struct {
	Timestamp string  `json:"@timestamp"`
	Supname   string  `json:"supname"`
	Action    string  `json:"action"`
	Message   string  `json:"message"`
	Ip        string  `json:"ip"`
	Level     int     `json:"level"`
	Cost      float64 `json:"cost"`
}

type Rsynccli

type Rsynccli struct {
	Se        SyncEntry
	Code      string
	Host      string
	Port      string
	Username  string
	Passwd    string
	Path      string
	LocalPath string
	File      string
	LocalFile string
	SyncTime  string
}

func NewRsynccli

func NewRsynccli(se SyncEntry) *Rsynccli

func (*Rsynccli) Rsync

func (cli *Rsynccli) Rsync() (rterr error)

type SyncEntry

type SyncEntry struct {
	Conf         string
	Supname      string
	Code         string
	LogPath      string
	Method       string
	SyncTime     string
	SyncEndTime  string
	SyncNext     map[string]SyncEntry
	LastSyncTime int64
	// contains filtered or unexported fields
}

func NewSyncEntry

func NewSyncEntry(cnf *config.Config, conf string, supname string) (SyncEntry, error)

func (SyncEntry) GetCostTime

func (se SyncEntry) GetCostTime() float64

func (*SyncEntry) GetCurrentSyncTime

func (se *SyncEntry) GetCurrentSyncTime() (int64, error)

func (SyncEntry) GetLastPullTime

func (se SyncEntry) GetLastPullTime() int64

func (SyncEntry) GetLastSyncTime

func (se SyncEntry) GetLastSyncTime() int64

func (*SyncEntry) GetSyncEndTime

func (se *SyncEntry) GetSyncEndTime() (int64, error)

func (*SyncEntry) GetYesterdaySyncTime

func (se *SyncEntry) GetYesterdaySyncTime() int64

func (*SyncEntry) RestCostTime

func (se *SyncEntry) RestCostTime()

func (SyncEntry) UpdateLastPullTime

func (se SyncEntry) UpdateLastPullTime(lastPullTime string)

func (SyncEntry) UpdateLastSyncTime

func (se SyncEntry) UpdateLastSyncTime()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL