qos

Documentation

Index

• func AsyncEntries(ctx context.Context) []model.QosEntryModel
• func EnsureContextWithQosEntryCollector(ctx context.Context) context.Context
• func ListSyncEntriesHandler(ctx context.Context) gin.HandlerFunc
• func RegisterAsyncEntry(ctx context.Context, e Entry)
• func RegisterSyncEntry(ctx context.Context, e Entry)
• func RunSyncEntryEndpointHandler(ctx context.Context) gin.HandlerFunc
• func SyncEntries(ctx context.Context) []model.QosEntryModel
• type Entry
  • func AsyncEntry(ctx context.Context, name string) (e Entry, found bool)
  • func NewFunctionEntry(name string, action func() float64) Entry
  • func SyncEntry(ctx context.Context, name string) (e Entry, found bool)

Functions

func AsyncEntries

func AsyncEntries(ctx context.Context) []model.QosEntryModel

func EnsureContextWithQosEntryCollector

func EnsureContextWithQosEntryCollector(ctx context.Context) context.Context

func ListSyncEntriesHandler

func ListSyncEntriesHandler(ctx context.Context) gin.HandlerFunc

func RegisterAsyncEntry

func RegisterAsyncEntry(ctx context.Context, e Entry)

func RegisterSyncEntry

func RegisterSyncEntry(ctx context.Context, e Entry)

func RunSyncEntryEndpointHandler

func RunSyncEntryEndpointHandler(ctx context.Context) gin.HandlerFunc

func SyncEntries

func SyncEntries(ctx context.Context) []model.QosEntryModel

Types

type Entry

type Entry interface {
	Run() float64
	Name() string
}

func AsyncEntry

func AsyncEntry(ctx context.Context, name string) (e Entry, found bool)

func NewFunctionEntry

func NewFunctionEntry(name string, action func() float64) Entry

func SyncEntry

func SyncEntry(ctx context.Context, name string) (e Entry, found bool)