distributedcontext

Documentation

Index

• func Do(ctx context.Context, f func(ctx context.Context))
• func NewContext(ctx context.Context, keyvalues ...core.KeyValue) context.Context
• func WithMap(ctx context.Context, m Map) context.Context
• type Map
  • func FromContext(ctx context.Context) Map
  • func NewEmptyMap() Map
  • func NewMap(update MapUpdate) Map
  • func (m Map) Apply(update MapUpdate) Map
  • func (m Map) Foreach(f func(kv core.KeyValue) bool)
  • func (m Map) HasValue(k core.Key) bool
  • func (m Map) Len() int
  • func (m Map) Value(k core.Key) (core.Value, bool)
• type MapUpdate

Functions

func Do

func Do(ctx context.Context, f func(ctx context.Context))

Note: the golang pprof.Do API forces this memory allocation, we should file an issue about that. (There's a TODO in the source.)

func NewContext

func NewContext(ctx context.Context, keyvalues ...core.KeyValue) context.Context

func WithMap

func WithMap(ctx context.Context, m Map) context.Context

Types

type Map

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

func FromContext

func FromContext(ctx context.Context) Map

func NewEmptyMap

func NewEmptyMap() Map

func NewMap

func NewMap(update MapUpdate) Map

func (Map) Apply

func (m Map) Apply(update MapUpdate) Map

func (Map) Foreach

func (m Map) Foreach(f func(kv core.KeyValue) bool)

func (Map) HasValue

func (m Map) HasValue(k core.Key) bool

func (Map) Len

func (m Map) Len() int

func (Map) Value

func (m Map) Value(k core.Key) (core.Value, bool)

type MapUpdate

type MapUpdate struct {
	SingleKV core.KeyValue
	MultiKV  []core.KeyValue
}