taskdebug

Documentation

Index

• type CPIAWSRPCMessage
• type ExternalCPIMessage
• type ExternalCPIRequestMessage
• type InstanceAspectChangedMessage
  • func (m InstanceAspectChangedMessage) GetChangedFromTags() map[string]interface{}
  • func (m InstanceAspectChangedMessage) GetChangedPackages() []string
  • func (m InstanceAspectChangedMessage) GetChangedToTags() map[string]interface{}
• type LockMessage
• type NATSMessageMessage
  • func (m NATSMessageMessage) GetReceivedDrainValue() int64
  • func (m NATSMessageMessage) GetReceivedState() string
  • func (m NATSMessageMessage) GetReceivedTaskID() string
• type NATSMessageSentAgentMessage
  • func (m NATSMessageSentAgentMessage) GetArgument0String() string
• type ProcessMessage
• type RawMessage
• type SequelMessage

Types

type CPIAWSRPCMessage

type CPIAWSRPCMessage struct {
	RawMessage

	Correlation   string
	Duration      time.Duration
	StatusCode    int
	Retries       int
	Payload       string
	PayloadMethod string
}

type ExternalCPIMessage

type ExternalCPIMessage struct {
	RawMessage

	Correlation string
	Event       string
	Remaining   string
}

type ExternalCPIRequestMessage

type ExternalCPIRequestMessage struct {
	ExternalCPIMessage

	Payload       string
	PayloadMethod string
	Command       string
}

type InstanceAspectChangedMessage

type InstanceAspectChangedMessage struct {
	RawMessage

	InstanceGroup string
	InstanceID    string
	InstanceIndex string // TODO int64?
	Aspect        string
	ChangedFrom   string
	ChangedTo     string
}

func (InstanceAspectChangedMessage) GetChangedFromTags

func (m InstanceAspectChangedMessage) GetChangedFromTags() map[string]interface{}

func (InstanceAspectChangedMessage) GetChangedPackages

func (m InstanceAspectChangedMessage) GetChangedPackages() []string

func (InstanceAspectChangedMessage) GetChangedToTags

func (m InstanceAspectChangedMessage) GetChangedToTags() map[string]interface{}

type LockMessage

type LockMessage struct {
	RawMessage

	Event string
	Name  string
	UID   string
}

type NATSMessageMessage

type NATSMessageMessage struct {
	RawMessage

	Event   string
	Channel string
	Payload string
}

func (NATSMessageMessage) GetReceivedDrainValue

func (m NATSMessageMessage) GetReceivedDrainValue() int64

func (NATSMessageMessage) GetReceivedState

func (m NATSMessageMessage) GetReceivedState() string

func (NATSMessageMessage) GetReceivedTaskID

func (m NATSMessageMessage) GetReceivedTaskID() string

type NATSMessageSentAgentMessage

type NATSMessageSentAgentMessage struct {
	NATSMessageMessage

	AgentID         string
	PayloadProtocol int
	PayloadMethod   string
	PayloadReplyTo  string
}

func (NATSMessageSentAgentMessage) GetArgument0String

func (m NATSMessageSentAgentMessage) GetArgument0String() string

type ProcessMessage

type ProcessMessage struct {
	RawMessage

	WorkerName   string
	InstanceName string
	InstanceID   string
	IP           string
}

type RawMessage

type RawMessage struct {
	log.RawLine

	LogTime   time.Time
	LogLevel  string
	Process   string
	Tags      map[string]string
	Component string
	Message   string
}

type SequelMessage

type SequelMessage struct {
	RawMessage

	Duration   time.Duration
	Connection string
	Query      string
}