busbridge

Documentation

Index

• func FromBridgePayload(payload string) (rmsg *msg.SzenarioEvtMsg, err error)
• func ToBridgePayload(msg *msg.SzenarioEvtMsg) (string, error)
• type BrigeMsg
• type Slack
  • func NewSlack(ctx context.Context, hcl hcl.Logger, oAuth string, appLevelToken string) (*Slack, error)
  • func (s Slack) Send(evt *msg.SzenarioEvtMsg) error

Functions

func FromBridgePayload

func FromBridgePayload(payload string) (rmsg *msg.SzenarioEvtMsg, err error)

FromBridgePayload converts from bridge payload

func ToBridgePayload

func ToBridgePayload(msg *msg.SzenarioEvtMsg) (string, error)

ToBridgePayload converts to bridge payload

Types

type BrigeMsg

type BrigeMsg struct {
	Type        string
	Src         uuid.UUID
	JSONPayload []byte
}

BrigeMsg is used to encapsulate eventbus messages when sending over a bridge

type Slack

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

Slack bridges the eventbus over slack

func NewSlack

func NewSlack(ctx context.Context, hcl hcl.Logger, oAuth string, appLevelToken string) (*Slack, error)

NewSlack creates a new slack event bridge

func (Slack) Send

func (s Slack) Send(evt *msg.SzenarioEvtMsg) error

Send messge to the bridge