transactional

Documentation

Index

• Constants
• type IntakePayload
  • func NewIntakePayload() IntakePayload
  • func (ip *IntakePayload) EqualDataPayload(ip2 IntakePayload) bool
  • func (ip *IntakePayload) JSONString() string
• type PayloadTransaction

Constants

const (
	// IntakePath is the path for the intake route on the receiver API
	IntakePath = "intake"
)

Types

type IntakePayload

type IntakePayload struct {
	InternalHostname string                     `json:"internalHostname"`
	Topologies       []topology.Topology        `json:"topologies"`
	Health           []health.Health            `json:"health"`
	Metrics          []interface{}              `json:"metrics"`
	Events           map[string][]metrics.Event `json:"events"`
}

IntakePayload is a Go representation of the Receiver Intake structure

func NewIntakePayload

func NewIntakePayload() IntakePayload

NewIntakePayload returns a IntakePayload with default values

func (*IntakePayload) EqualDataPayload

func (ip *IntakePayload) EqualDataPayload(ip2 IntakePayload) bool

EqualDataPayload compares the topology, health and metrics of two IntakePayloads and returns a bool indicating whether the intake payloads are equal

func (*IntakePayload) JSONString

func (ip *IntakePayload) JSONString() string

JSONString returns a JSON string of the Component

type PayloadTransaction

type PayloadTransaction struct {
	ActionID             string
	CompletedTransaction bool
}

PayloadTransaction is used to keep track of a given actionID and completion status of a transaction when submitting payloads