taskdebug

package
v0.0.0-...-63a51b9 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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