metrics

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

type AgentConfig struct {
	Source              interface{}
	RetryAttempts       int
	RetryInitialBackoff time.Duration
	RetryMaxBackoff     time.Duration
	RetryBudget         time.Duration
}

type AmqpSinkConfig struct {
	Url       string `cf:"+secret"`
	QueueName string
}

type AmqpSourceConfig struct {
	Url       string `cf:"+secret"`
	QueueName string
	Prefetch  int
}

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

type BridgeConfig struct {
	Source interface{}
	Sink   interface{}
}

type Config struct {
	Influx *InfluxConfig
	Agent  *AgentConfig
}

type FileSourceConfig struct {
	Path        string
	PointerPath string
}

type InfluxConfig struct {
	Url          string
	Bucket       string
	Org          string
	Token        string `cf:"+secret"`
	WriteTimeout time.Duration
}

type Usage struct {
	ProcessedStamp time.Time
	IntervalStart  time.Time
	ZitiServiceId  string
	ZitiCircuitId  string
	ShareToken     string
	EnvironmentId  int64
	AccountId      int64
	FrontendTx     int64
	FrontendRx     int64
	BackendTx      int64
	BackendRx      int64
}

type UsageSink interface {
	Handle(u *Usage) error
}

type WebsocketSourceConfig struct {
	WebsocketEndpoint string // wss://127.0.0.1:1280/fabric/v1/ws-api
	ApiEndpoint       string // https://127.0.0.1:1280
	Username          string
	Password          string `cf:"+secret"`
}

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

type ZitiEventJson string

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

type ZitiEventJsonSink interface {
	Handle(event ZitiEventJson) error
}

type ZitiEventJsonSource interface {
	Start(chan ZitiEventMsg) (join chan struct{}, err error)
	Stop()
}

type ZitiEventMsg interface {
	Data() ZitiEventJson
	Ack() error
	Nack(requeue bool) error
}