provider

Documentation

Index

• type ManagerCmdType
• type ManagerCommand
• type NewProviderPayload
• type Option
  • func WithConfig(cfg config.Config) Option
  • func WithPersistence(db *pgxpool.Pool) Option
  • func WithWampClient(wampClient *client.Client) Option
• type ProviderManager
  • func NewProviderManager(opts ...Option) (*ProviderManager, error)
  • func (pm *ProviderManager) ProviderLookupFunc(key string) *service.ProviderData
  • func (pm *ProviderManager) Shutdown()
• type ProviderResponseData
• type PublishNew
• type PublishRemoved

Types

type ManagerCmdType

type ManagerCmdType int

const (
	Register ManagerCmdType = 1
	Removed  ManagerCmdType = 2
)

type ManagerCommand

type ManagerCommand struct {
	Type ManagerCmdType `json:"type"`
}

type NewProviderPayload

type NewProviderPayload struct {
	EventKey  string              `json:"eventKey"`
	Manifests model.Manifests     `json:"manifests"`
	Info      model.EventDataInfo `json:"info"`
}

type Option

type Option func(*ProviderManager)

func WithConfig

func WithConfig(cfg config.Config) Option

func WithPersistence

func WithPersistence(db *pgxpool.Pool) Option

func WithWampClient

func WithWampClient(wampClient *client.Client) Option

type ProviderManager

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

func NewProviderManager

func NewProviderManager(opts ...Option) (*ProviderManager, error)

func (*ProviderManager) ProviderLookupFunc

func (pm *ProviderManager) ProviderLookupFunc(key string) *service.ProviderData

func (*ProviderManager) Shutdown

func (pm *ProviderManager) Shutdown()

type ProviderResponseData

type ProviderResponseData struct {
	EventKey   string              `json:"eventKey"`
	Manifests  model.Manifests     `json:"manifests"`
	Info       model.EventDataInfo `json:"info"`
	RecordDate time.Time           `json:"recordDate"`
	DbId       int                 `json:"dbId"`
}

contains the data sent to the client when using provider endpoints

type PublishNew

type PublishNew struct {
	Type    ManagerCmdType     `json:"type"`
	Payload NewProviderPayload `json:"payload"`
}

type PublishRemoved

type PublishRemoved struct {
	Type    ManagerCmdType `json:"type"`
	Payload string         `json:"payload"` // contains the event key
}