provider

Documentation

Index

• type ManagerCmdType
• type ManagerCommand
• type NewProviderPayload
• type ProviderManager
  • func InitProviderEndpoints(pool *pgxpool.Pool) (*ProviderManager, error)
  • 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 ProviderManager

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

func InitProviderEndpoints

func InitProviderEndpoints(pool *pgxpool.Pool) (*ProviderManager, error)

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
}