bgs

Documentation

Index

• Variables
• type BGS
  • func NewBGS(db *gorm.DB, ix *indexer.Indexer, repoman *repomgr.RepoManager, ...) *BGS
  • func (bgs *BGS) EventsHandler(c echo.Context) error
  • func (bgs *BGS) Start(listen string) error
• type IndexCallback
• type PDS
• type Slurper
  • func NewSlurper(db *gorm.DB, cb IndexCallback) *Slurper
  • func (s *Slurper) SubscribeToPds(ctx context.Context, host string) error
• type User

Variables

var ErrTimeoutShutdown = fmt.Errorf("timed out waiting for new events")

var EventsTimeout = time.Minute

Types

type BGS

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

func NewBGS

func NewBGS(db *gorm.DB, ix *indexer.Indexer, repoman *repomgr.RepoManager, evtman *events.EventManager, didr plc.PLCClient) *BGS

func (*BGS) EventsHandler

func (bgs *BGS) EventsHandler(c echo.Context) error

func (*BGS) Start

func (bgs *BGS) Start(listen string) error

type IndexCallback

type IndexCallback func(context.Context, *PDS, *events.Event) error

type PDS

type PDS struct {
	gorm.Model

	Host string
}

type Slurper

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

TODO: rename me

func NewSlurper

func NewSlurper(db *gorm.DB, cb IndexCallback) *Slurper

func (*Slurper) SubscribeToPds

func (s *Slurper) SubscribeToPds(ctx context.Context, host string) error

type User

type User struct {
	gorm.Model
	Handle string `gorm:"uniqueIndex"`
	Did    string `gorm:"uniqueIndex"`
	PDS    uint
}