util

Documentation

Index

• func AddrsFromProto(pa []netpb.ProtoAddr) []ma.Multiaddr
• func AddrsToProto(mas []ma.Multiaddr) []netpb.ProtoAddr
• func LogFromProto(l *netpb.Log) thread.LogInfo
• func LogToProto(l thread.LogInfo) *netpb.Log
• 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 AddrsFromProto

func AddrsFromProto(pa []netpb.ProtoAddr) []ma.Multiaddr

func AddrsToProto

func AddrsToProto(mas []ma.Multiaddr) []netpb.ProtoAddr

func LogFromProto

func LogFromProto(l *netpb.Log) thread.LogInfo

LogFromProto returns a thread log from a proto log.

func LogToProto

func LogToProto(l thread.LogInfo) *netpb.Log

LogToProto returns a proto log from a thread log.

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()