incomingtrafficholder

Documentation

Index

• type IP
• type IncomingTrafficCallbackFunc
• type IncomingTrafficIntent
• type IncomingTrafficIntentsHolder
  • func NewIncomingTrafficIntentsHolder() *IncomingTrafficIntentsHolder
  • func (h *IncomingTrafficIntentsHolder) AddIntent(intent IncomingTrafficIntent)
  • func (h *IncomingTrafficIntentsHolder) GetNewIntentsSinceLastGet() []TimestampedIncomingTrafficIntent
  • func (h *IncomingTrafficIntentsHolder) PeriodicIntentsUpload(ctx context.Context, interval time.Duration)
  • func (h *IncomingTrafficIntentsHolder) RegisterNotifyIntents(callback IncomingTrafficCallbackFunc)
• type IncomingTrafficKey
• type TimestampedIncomingTrafficIntent

Types

type IP

type IP string

type IncomingTrafficCallbackFunc

type IncomingTrafficCallbackFunc func(context.Context, []TimestampedIncomingTrafficIntent)

type IncomingTrafficIntent

type IncomingTrafficIntent struct {
	Server   model.OtterizeServiceIdentity `json:"client"`
	LastSeen time.Time
	IP       string
}

type IncomingTrafficIntentsHolder

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

func NewIncomingTrafficIntentsHolder

func NewIncomingTrafficIntentsHolder() *IncomingTrafficIntentsHolder

func (*IncomingTrafficIntentsHolder) AddIntent

func (h *IncomingTrafficIntentsHolder) AddIntent(intent IncomingTrafficIntent)

func (*IncomingTrafficIntentsHolder) GetNewIntentsSinceLastGet

func (h *IncomingTrafficIntentsHolder) GetNewIntentsSinceLastGet() []TimestampedIncomingTrafficIntent

func (*IncomingTrafficIntentsHolder) PeriodicIntentsUpload

func (h *IncomingTrafficIntentsHolder) PeriodicIntentsUpload(ctx context.Context, interval time.Duration)

func (*IncomingTrafficIntentsHolder) RegisterNotifyIntents

func (h *IncomingTrafficIntentsHolder) RegisterNotifyIntents(callback IncomingTrafficCallbackFunc)

type IncomingTrafficKey

type IncomingTrafficKey struct {
	ServerName      string
	ServerNamespace string
	IP              string
}

type TimestampedIncomingTrafficIntent

type TimestampedIncomingTrafficIntent struct {
	Timestamp time.Time
	Intent    IncomingTrafficIntent
}