transfer

Documentation

Index

• type OriginPeriod
• type RequestMessage
• type ResponseMessage
• type TransferRequester
  • func NewTransferRequester(c *config.TransferConfig) *TransferRequester
  • func (t *TransferRequester) Run()
• type TransferResponder
  • func NewTransferResponder(c *config.TransferConfig) *TransferResponder
  • func (t *TransferResponder) Run(publisher *nanomsg.Publisher[message.Mapped])

Types

type OriginPeriod

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

type RequestMessage

type RequestMessage struct {
	Command       string            `json:"command"`
	UUID          uuid.UUID         `json:"uuid"`
	PeriodStart   time.Time         `json:"period_start"`
	CountsPerUuid map[uuid.UUID]int `json:"counts_per_uuid,omitempty"` // map of raw_data uuids we got mapped_data for, the number is the number of data points we already have per raw_data uuid
}

type ResponseMessage

type ResponseMessage struct {
	Command     string    `json:"command"`
	UUID        uuid.UUID `json:"uuid"`
	PeriodStart time.Time `json:"period_start"`
	DataPoints  int       `json:"data_points"`
}

type TransferRequester

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

func NewTransferRequester

func NewTransferRequester(c *config.TransferConfig) *TransferRequester

func (*TransferRequester) Run

func (t *TransferRequester) Run()

type TransferResponder

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

func NewTransferResponder

func NewTransferResponder(c *config.TransferConfig) *TransferResponder

func (*TransferResponder) Run

func (t *TransferResponder) Run(publisher *nanomsg.Publisher[message.Mapped])