internal

Documentation

Index

• Variables
• type CtxMutex
  • func NewCtxMutex() CtxMutex
  • func (m CtxMutex) Lock(ctx context.Context) error
  • func (m CtxMutex) Unlock()
• type LoggableProviderRecordBytes
  • func (lk LoggableProviderRecordBytes) String() string
• type LoggableRecordKeyBytes
  • func (lk LoggableRecordKeyBytes) String() string
• type LoggableRecordKeyString
  • func (lk LoggableRecordKeyString) String() string

Variables

var ErrInvalidRecord = errors.New("received invalid record")

Types

type CtxMutex

type CtxMutex chan struct{}

func NewCtxMutex

func NewCtxMutex() CtxMutex

func (CtxMutex) Lock

func (m CtxMutex) Lock(ctx context.Context) error

func (CtxMutex) Unlock

func (m CtxMutex) Unlock()

type LoggableProviderRecordBytes

type LoggableProviderRecordBytes []byte

func (LoggableProviderRecordBytes) String

func (lk LoggableProviderRecordBytes) String() string

type LoggableRecordKeyBytes

type LoggableRecordKeyBytes []byte

func (LoggableRecordKeyBytes) String

func (lk LoggableRecordKeyBytes) String() string

type LoggableRecordKeyString

type LoggableRecordKeyString string

func (LoggableRecordKeyString) String

func (lk LoggableRecordKeyString) String() string