power_state_topic

Documentation

Index

• Constants
• func New(channel *amqp.Channel) topic.PowerStateJob
• type PowerStateExchange
  • func (t *PowerStateExchange) Init(ctx context.Context, channel *amqp.Channel) error
  • func (t *PowerStateExchange) SendRequestStateChangeMessage(ctx context.Context, msg *power.RequestStateChangeMessage) error
  • func (t *PowerStateExchange) SendStateValidationMessage(ctx context.Context, msg *power.StateValidationMessage) error

Constants

const (
	ExchangeName                 = "power_state"
	ExchangeTypeTopic            = "topic"
	RequestStateChangeRequestKey = "power_state.request_state_change"
	StateValidationRequestKey    = "power_state.state_validation"
)

Functions

func New

func New(channel *amqp.Channel) topic.PowerStateJob

Types

type PowerStateExchange

type PowerStateExchange struct {
	// contains filtered or unexported fields
}

func (*PowerStateExchange) Init

func (t *PowerStateExchange) Init(ctx context.Context, channel *amqp.Channel) error

func (*PowerStateExchange) SendRequestStateChangeMessage

func (t *PowerStateExchange) SendRequestStateChangeMessage(ctx context.Context, msg *power.RequestStateChangeMessage) error

func (*PowerStateExchange) SendStateValidationMessage

func (t *PowerStateExchange) SendStateValidationMessage(ctx context.Context, msg *power.StateValidationMessage) error