omtools

package module
v0.0.0-...-8163f96 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 22, 2023 License: Apache-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Debugf

func Debugf(template string, args ...interface{})

func DumpAssignment

func DumpAssignment(as *pb.Assignment) string

func Errorf

func Errorf(template string, args ...interface{})

func Fatalf

func Fatalf(template string, args ...interface{})

func Infof

func Infof(template string, args ...interface{})

func Warnf

func Warnf(template string, args ...interface{})

Types

type Assigner

type Assigner interface {
	Assign(ctx context.Context, matches []*pb.Match) ([]*pb.AssignmentGroup, error)
}

type DefaultLogger

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

func (*DefaultLogger) Debugf

func (l *DefaultLogger) Debugf(template string, args ...interface{})

func (*DefaultLogger) Errorf

func (l *DefaultLogger) Errorf(template string, args ...interface{})

func (*DefaultLogger) Fatalf

func (l *DefaultLogger) Fatalf(template string, args ...interface{})

func (*DefaultLogger) Infof

func (l *DefaultLogger) Infof(template string, args ...interface{})

func (*DefaultLogger) Warnf

func (l *DefaultLogger) Warnf(template string, args ...interface{})

type Director

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

func NewDirector

func NewDirector(backend pb.BackendServiceClient,
	profile *pb.MatchProfile, mfConfig *pb.FunctionConfig,
	assigner Assigner, opts ...DirectorOption) *Director

func (*Director) AssignTickets

func (d *Director) AssignTickets(ctx context.Context, matches []*pb.Match) ([]*pb.AssignmentGroup, error)

func (*Director) FetchMatches

func (d *Director) FetchMatches(ctx context.Context) ([]*pb.Match, error)

func (*Director) Run

func (d *Director) Run(ctx context.Context, tickRate time.Duration) error

type DirectorOption

type DirectorOption interface {
	// contains filtered or unexported methods
}

func WithDirectorLogger

func WithDirectorLogger(logger Logger) DirectorOption

type DirectorOptionFunc

type DirectorOptionFunc func(options *directorOptions)

type HasExtensions

type HasExtensions interface {
	GetExtensions() map[string]*anypb.Any
}

type Logger

type Logger interface {
	Debugf(template string, args ...interface{})
	Infof(template string, args ...interface{})
	Warnf(template string, args ...interface{})
	Errorf(template string, args ...interface{})
	Fatalf(template string, args ...interface{})
}

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL