broker

Documentation

Index

• Variables
• type EventType
• type Handler
• type Message
• type ObjectType
• type PublishInterface
• type SubscribeInterface

Variables

var (
	List   ObjectType = "list"
	Single ObjectType = "single"

	Add    EventType = "ADDED"
	Update EventType = "MODIFIED"
	Delete EventType = "DELETED"
	Error  EventType = "ERROR"
)

Types

type EventType

type EventType string

type Handler

type Handler interface {
	PublishInterface
	SubscribeInterface
	Info() string
}

type Message

type Message struct {
	ObjectType ObjectType
	EventType  EventType
	Object     interface{}
}

type ObjectType

type ObjectType string

type PublishInterface

type PublishInterface interface {
	Publish(string, *Message) error
	PublishWithChannel(string, chan *Message) error
}

type SubscribeInterface

type SubscribeInterface interface {
	Subscribe(string, string, []byte) error
	SubscribeWithChannel(string, string, chan *Message) error
}