notification

Documentation

Index

• Variables
• type Endpoint
  • func EndpointFromString(e string) (Endpoint, error)
  • func (i Endpoint) String() string
• type ExecutionMessage
  • func DeserializeExecutionMessage(b []byte) (ExecutionMessage, error)
  • func NewExecutionMessage(e workflow.ExecutionIdentifier, w workflow.WorkflowName, ...) ExecutionMessage
  • func (e ExecutionMessage) Serialize() (string, error)
• type Identifier
  • func IdentifierFromString(id string) (Identifier, error)
  • func (i Identifier) String() string
• type Notifier
  • func NewNotifier(name Identifier, topicType TopicType, endpoint Endpoint) *Notifier
  • func NewNotifierFromPrimitive(name string, topicType string, endpoint string) (*Notifier, 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 Endpoint

type Endpoint string

func EndpointFromString

func EndpointFromString(e string) (Endpoint, error)

func (Endpoint) String

func (i Endpoint) String() string

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 Identifier

type Identifier string

func IdentifierFromString

func IdentifierFromString(id string) (Identifier, error)

func (Identifier) String

func (i Identifier) String() string

type Notifier

type Notifier struct {
	Name     Identifier
	Type     TopicType
	Endpoint Endpoint
}

func NewNotifier

func NewNotifier(name Identifier, topicType TopicType, endpoint Endpoint) *Notifier

func NewNotifierFromPrimitive

func NewNotifierFromPrimitive(name string, topicType string, endpoint string) (*Notifier, 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