topic

Documentation

Index

• Constants
• func NewTopicManager(p *pi.Pi) *topicManager
• func PushEvent(e *etcd.Etcd, uid string, t messageType, model model) error
• type Message
• type Resource
  • func NewResource(rtype, rid string) Resource
  • func (r Resource) GetTopicResource() Resource
  • func (r Resource) SetStatus(status string) Resource
  • func (r Resource) SetTransitionStatus(transitionStatus string) Resource

Constants

const (
	Create messageType = "create"
	Update messageType = "update"
	Delete messageType = "delete"
)

Functions

func NewTopicManager

func NewTopicManager(p *pi.Pi) *topicManager

func PushEvent

func PushEvent(e *etcd.Etcd, uid string, t messageType, model model) error

Types

type Message

type Message struct {
	// Type: optional create/delete/update
	Type     messageType `json:"type,omitempty"`
	Resource Resource    `json:"resource_set,omitempty"`
}

type Resource

type Resource struct {
	ResourceType     string  `json:"rtype,omitempty"`
	ResourceId       string  `json:"rid,omitempty"`
	Status           *string `json:"status,omitempty"`
	TransitionStatus *string `json:"tstatus,omitempty"`
}

func NewResource

func NewResource(rtype, rid string) Resource

func (Resource) GetTopicResource

func (r Resource) GetTopicResource() Resource

func (Resource) SetStatus

func (r Resource) SetStatus(status string) Resource

func (Resource) SetTransitionStatus

func (r Resource) SetTransitionStatus(transitionStatus string) Resource