http

Documentation

Index

• Constants
• type HttpListenerMetric
• type KentikHttpListener
  • func NewHttpListener(ctx context.Context, host string, log logger.Underlying, ...) (*KentikHttpListener, error)
  • func (ks *KentikHttpListener) Close()
  • func (ks *KentikHttpListener) HttpInfo() map[string]float64
  • func (ks *KentikHttpListener) RegisterRoutes(r *kmux.Router)

Constants

const (
	CHAN_SLACK           = 10000
	DeviceUpdateDuration = 1 * time.Hour
	Listen               = "/input"
)

Types

type HttpListenerMetric

type HttpListenerMetric struct {
	Messages go_metrics.Meter
	Errors   go_metrics.Meter
}

type KentikHttpListener

type KentikHttpListener struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewHttpListener

func NewHttpListener(ctx context.Context, host string, log logger.Underlying, registry go_metrics.Registry, jchfChan chan []*kt.JCHF, apic *api.KentikApi) (*KentikHttpListener, error)

func (*KentikHttpListener) Close

func (ks *KentikHttpListener) Close()

func (*KentikHttpListener) HttpInfo

func (ks *KentikHttpListener) HttpInfo() map[string]float64

func (*KentikHttpListener) RegisterRoutes

func (ks *KentikHttpListener) RegisterRoutes(r *kmux.Router)