pubsub

Documentation

Index

• type CommitNotification
• type PubSubManager
  • func NewPubSubManager() *PubSubManager
  • func (cc *PubSubManager) PublishCommit(fsId, namespace, name, branch, commitId string, metadata map[string]string) error
  • func (cc *PubSubManager) SubscribeForCommits(url, username, password, subject string) error
  • func (cc *PubSubManager) UnsubscribeForCommits(url, username, subject string) error

Types

type CommitNotification

type CommitNotification struct {
	FilesystemId string
	Namespace    string
	Name         string
	Branch       string
	CommitId     string
	Metadata     map[string]string
}

type PubSubManager

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

func NewPubSubManager

func NewPubSubManager() *PubSubManager

func (*PubSubManager) PublishCommit

func (cc *PubSubManager) PublishCommit(fsId, namespace, name, branch, commitId string, metadata map[string]string) error

func (*PubSubManager) SubscribeForCommits

func (cc *PubSubManager) SubscribeForCommits(url, username, password, subject string) error

func (*PubSubManager) UnsubscribeForCommits

func (cc *PubSubManager) UnsubscribeForCommits(url, username, subject string) error