common

Documentation

Index

• func IsNotFound(err error) bool
• func IsUnknown(err error) bool
• func NotFoundError(message string) error
• func Wrap(err1 error, err2 error) error
• type Event
• type Logger
  • func NewLogger(name string, names ...string) Logger
  • func NewLoggerWithLogr(l logr.Logger) Logger
• type RateLimiter
  • func NewDefaultRateLimiter() RateLimiter
  • func (r RateLimiter) Wait(ctx context.Context, event Event) error

Functions

func IsNotFound

func IsNotFound(err error) bool

func IsUnknown

func IsUnknown(err error) bool

func NotFoundError

func NotFoundError(message string) error

func Wrap

func Wrap(err1 error, err2 error) error

Types

type Event

type Event string

const (
	ListNamespaces      Event = "ListNamespaces"
	ListServices        Event = "ListServices"
	GetOperation        Event = "GetOperation"
	DiscoverInstances   Event = "DiscoverInstances"
	CreateHttpNamespace Event = "CreateHttpNamespace"
	CreateService       Event = "CreateService"
	RegisterInstance    Event = "RegisterInstance"
	DeregisterInstance  Event = "DeregisterInstance"
)

type Logger

type Logger interface {
	Info(msg string, keysAndValues ...interface{})
	Debug(msg string, keysAndValues ...interface{})
	Error(err error, msg string, keysAndValues ...interface{})
}

func NewLogger

func NewLogger(name string, names ...string) Logger

func NewLoggerWithLogr

func NewLoggerWithLogr(l logr.Logger) Logger

type RateLimiter

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

func NewDefaultRateLimiter

func NewDefaultRateLimiter() RateLimiter

NewDefaultRateLimiter returns the rate limiters with the default limits for the AWS CloudMap's API calls

func (RateLimiter) Wait

func (r RateLimiter) Wait(ctx context.Context, event Event) error

Wait blocks until limit permits an event to happen. It returns an error if the Context is canceled, or the expected wait time exceeds the Context's Deadline.