message

Documentation

Index

• type MessagePack
  • func NewMsgPack(connectorName string, targetUser string, jobContext *slurmjob.JobContext) (*MessagePack, error)

Types

type MessagePack

type MessagePack struct {
	Connector  string
	TargetUser string
	JobContext *slurmjob.JobContext
	TimeStamp  time.Time
}

MessagePack is the central data structure that holds all the data about the message that is currently being processed. It is used to pass the "message" and its "metadata" between all of the components of the system, e.g. main->connector->spooler->gobler->sender etc.

func NewMsgPack

func NewMsgPack(connectorName string, targetUser string, jobContext *slurmjob.JobContext) (*MessagePack, error)

NewMsgPack returns the instantiated message.MessagePack structure