res_watch

Documentation

Index

• type Event
• type Message
• type ReqData
  • func ParseReq(rt string) (*ReqData, error)
• type ResWatchSubs
• type ResWatchSubsMap
• type Response

Types

type Event

type Event string

const (
	EventSubscribe   Event = "subscribe"
	EventUnsubscribe Event = "unsubscribe"
)

type Message

type Message struct {
	ResPath string
	Id      string
	Event   Event
}

type ReqData

type ReqData struct {
	AccountName string `json:"account"`
	ProjectName string `json:"project"`

	// ResourceName string `json:"resource"`
	// ResourceType string `json:"resource_type"`
	Topic    string `json:"topic"`
	ReqTopic string `json:"req_topic"`
}

func ParseReq

func ParseReq(rt string) (*ReqData, error)

type ResWatchSubs

type ResWatchSubs struct {
	Sub      *mnats.Subscription
	Resource ReqData
}

type ResWatchSubsMap

type ResWatchSubsMap map[string]ResWatchSubs

type Response

type Response struct {
}