util

Documentation

Index

• func RecFromServiceRec(r *netpb.Log_Record) *apipb.Record
• func RecToServiceRec(r *apipb.Record) *netpb.Log_Record
• type Semaphore
  • func NewSemaphore(capacity int) *Semaphore
  • func (s *Semaphore) Acquire()
  • func (s *Semaphore) Release()
  • func (s *Semaphore) TryAcquire() bool
• type SemaphoreKey
• type SemaphorePool
  • func NewSemaphorePool(semaCap int) *SemaphorePool
  • func (p *SemaphorePool) Get(k SemaphoreKey) *Semaphore
  • func (p *SemaphorePool) Stop()

Functions

func RecFromServiceRec

func RecFromServiceRec(r *netpb.Log_Record) *apipb.Record

func RecToServiceRec

func RecToServiceRec(r *apipb.Record) *netpb.Log_Record

Types

type Semaphore

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

func NewSemaphore

func NewSemaphore(capacity int) *Semaphore

func (*Semaphore) Acquire

func (s *Semaphore) Acquire()

Blocking acquire

func (*Semaphore) Release

func (s *Semaphore) Release()

func (*Semaphore) TryAcquire

func (s *Semaphore) TryAcquire() bool

Non-blocking acquire

type SemaphoreKey

type SemaphoreKey interface {
	Key() string
}

type SemaphorePool

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

func NewSemaphorePool

func NewSemaphorePool(semaCap int) *SemaphorePool

func (*SemaphorePool) Get

func (p *SemaphorePool) Get(k SemaphoreKey) *Semaphore

func (*SemaphorePool) Stop

func (p *SemaphorePool) Stop()