harness

Documentation

Index

• func OpenDB(db_endpoint string) (db *gorm.DB, err error)
• type Controller
  • func NewController(addr string, db_endpoint string, logfile io.Writer) *Controller
  • func (c *Controller) Start()
  • func (c *Controller) Stop()
• type Producer
  • func NewProducer(prefix string, addr string, control_addr string, logfile io.Writer) *Producer
  • func (p *Producer) Start()
  • func (p *Producer) Stop()
• type WebClient
  • func NewWebClient(addr string, logfile io.Writer) *WebClient
  • func (w *WebClient) Start()
  • func (w *WebClient) Stop()

Functions

func OpenDB

func OpenDB(db_endpoint string) (db *gorm.DB, err error)

Types

type Controller

type Controller struct {
	Addr       string
	DBEndpoint string

	Logger *log.Logger
	// contains filtered or unexported fields
}

func NewController

func NewController(addr string, db_endpoint string, logfile io.Writer) *Controller

func (*Controller) Start

func (c *Controller) Start()

func (*Controller) Stop

func (c *Controller) Stop()

type Producer

type Producer struct {
	Addr        string
	ControlAddr string
	Prefix      string

	Logger *log.Logger
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(prefix string, addr string, control_addr string, logfile io.Writer) *Producer

func (*Producer) Start

func (p *Producer) Start()

func (*Producer) Stop

func (p *Producer) Stop()

type WebClient

type WebClient struct {
	Addr        string
	ControlAddr string
	Router      *gin.Engine

	Logger *log.Logger
	// contains filtered or unexported fields
}

func NewWebClient

func NewWebClient(addr string, logfile io.Writer) *WebClient

func (*WebClient) Start

func (w *WebClient) Start()

func (*WebClient) Stop

func (w *WebClient) Stop()