signals

Documentation

Index

• Constants
• Variables
• func CreateSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)
• func DeleteSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)
• func DispatchMessage(db *gorm.DB) pubsub.Callback
• func GetAllSignalsHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)
• func GetSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)
• func MigrateDB(db *gorm.DB) error
• func UpdateSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)
• func UpdateSignalStatus(db *gorm.DB, msg *pubsub.Message) error
• type JSONB
  • func (j *JSONB) Scan(value interface{}) error
  • func (j JSONB) Value() (driver.Value, error)
• type Signal
  • func (a *Signal) ToPubsubMessage(nextAction string) (*pubsub.Message, error)

Constants

const (
	SignalStatusNew = iota
	SignalStatusRejected
	SignalStatusResolved
)

const (
	TrendSignalType = "trend"
)

Variables

var SignalTypes = map[string]bool{
	TrendSignalType: false,
}

Functions

func CreateSignalHandler

func CreateSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)

func DeleteSignalHandler

func DeleteSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)

func DispatchMessage

func DispatchMessage(db *gorm.DB) pubsub.Callback

func GetAllSignalsHandler

func GetAllSignalsHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)

func GetSignalHandler

func GetSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)

func MigrateDB

func MigrateDB(db *gorm.DB) error

func UpdateSignalHandler

func UpdateSignalHandler(db *gorm.DB, w http.ResponseWriter, r *http.Request)

func UpdateSignalStatus

func UpdateSignalStatus(db *gorm.DB, msg *pubsub.Message) error

Types

type JSONB

type JSONB map[string]interface{}

func (*JSONB) Scan

func (j *JSONB) Scan(value interface{}) error

func (JSONB) Value

func (j JSONB) Value() (driver.Value, error)

type Signal

type Signal struct {
	gorm.Model
	UUID    string `sql:"type:uuid;primary_key;default:uuid_generate_v4()"`
	Type    string
	Status  string
	Error   string
	Payload JSONB `gorm:"not null"`
}

func (*Signal) ToPubsubMessage

func (a *Signal) ToPubsubMessage(nextAction string) (*pubsub.Message, error)