notify

Documentation

Index

• type NotifyEntry
• type NotifySender
  • func NewNotifySender(centerHost string, runtime string, key string, ipAddr string) *NotifySender
  • func (sender *NotifySender) SendExecuteMessage(jobid string, state int, execerr string, execat time.Time, nextat time.Time)
  • func (sender *NotifySender) SendLog(jobid string, command string, workdir string, state int, stdout string, ...)
  • func (sender *NotifySender) SendSelectMessage(jobid string, nextat time.Time)
• type NotifyType
  • func (notifyType NotifyType) String() string

Types

type NotifyEntry

type NotifyEntry struct {
	NotifyType
	MsgID   string
	To      string
	Subject string
	Data    interface{}
}

NotifyEntry is exported

type NotifySender

type NotifySender struct {
	Runtime    string
	Key        string
	IPAddr     string
	CenterHost string
	// contains filtered or unexported fields
}

NotifySender is exported

func NewNotifySender

func NewNotifySender(centerHost string, runtime string, key string, ipAddr string) *NotifySender

NewNotifySender is exported

func (*NotifySender) SendExecuteMessage

func (sender *NotifySender) SendExecuteMessage(jobid string, state int, execerr string, execat time.Time, nextat time.Time)

SendExecuteMessage is exported

func (*NotifySender) SendLog

func (sender *NotifySender) SendLog(jobid string, command string, workdir string, state int,
	stdout string, errout string, execerr string, execat time.Time, exectimes float64)

SendLog is exported

func (*NotifySender) SendSelectMessage

func (sender *NotifySender) SendSelectMessage(jobid string, nextat time.Time)

SendSelectMessage is exported

type NotifyType

type NotifyType int

const (
	NOTIFY_MESSAGE NotifyType = iota + 1
	NOTIFY_LOG
)

func (NotifyType) String

func (notifyType NotifyType) String() string