usage

Documentation

Index

• func HandleData(deps Dependencies, data []byte)
• func HandleRequest(deps Dependencies, reply string, data []byte)
• func RequestAll(deps Dependencies, req core.UsageRequest, timeout time.Duration, ...) ([]core.UsageRecord, error)
• type Dependencies

Functions

func HandleData

func HandleData(deps Dependencies, data []byte)

func HandleRequest

func HandleRequest(deps Dependencies, reply string, data []byte)

func RequestAll

func RequestAll(deps Dependencies, req core.UsageRequest, timeout time.Duration, subject string) ([]core.UsageRecord, error)

Types

type Dependencies

type Dependencies struct {
	State               *core.NodeState
	Publish             func(subject string, data []byte) error
	PublishMsgWithReply func(subject, reply string, data []byte) error
	Subscribe           func(subject string, cb func(*nats.Msg)) (*nats.Subscription, error)
	CountActiveDns      func() int
	MarkNodeHeard       func(string)
	UsageDataSubject    string
}