notification

Documentation

Index

• Variables
• type ExecutionMessage
  • func DeserializeExecutionMessage(b []byte) (ExecutionMessage, error)
  • func NewExecutionMessage(e workflow.ExecutionIdentifier, w workflow.WorkflowName, ...) ExecutionMessage
  • func (e ExecutionMessage) Serialize() (string, error)
• type Topic
  • func NewTopic(topicType TopicType, topicEndpoint TopicEndpoint) Topic
• type TopicEndpoint
  • func TopicEndpointFromString(s string) (TopicEndpoint, error)
  • func (x TopicEndpoint) String() string
• type TopicType
  • func TopicTypeFromString(s string) (TopicType, error)
  • func (x TopicType) String() string

Variables

var (
	ErrUnknownTopicType = errors.New("unknown topic type")
)

Types

type ExecutionMessage

type ExecutionMessage struct {
	WorkflowName string `json:"workflowName"`
	ExecutionId  string `json:"executionId"`
	Status       string `json:"status"`
	Results      string `json:"results"`
}

func DeserializeExecutionMessage

func DeserializeExecutionMessage(b []byte) (ExecutionMessage, error)

func NewExecutionMessage

func NewExecutionMessage(e workflow.ExecutionIdentifier, w workflow.WorkflowName, status workflow.Status, msg, results string) ExecutionMessage

func (ExecutionMessage) Serialize

func (e ExecutionMessage) Serialize() (string, error)

type Topic

type Topic struct {
	TopicType     TopicType
	TopicEndpoint TopicEndpoint
}

func NewTopic

func NewTopic(topicType TopicType, topicEndpoint TopicEndpoint) Topic

type TopicEndpoint

type TopicEndpoint string

func TopicEndpointFromString

func TopicEndpointFromString(s string) (TopicEndpoint, error)

func (TopicEndpoint) String

func (x TopicEndpoint) String() string

type TopicType

type TopicType int

const (
	TopicTypeUnknown TopicType = iota
	TopicTypeSns
	TopicTypeMqtt
)

func TopicTypeFromString

func TopicTypeFromString(s string) (TopicType, error)

func (TopicType) String

func (x TopicType) String() string