Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RecFromServiceRec ¶
func RecFromServiceRec(r *netpb.Log_Record) *apipb.Record
func RecToServiceRec ¶
func RecToServiceRec(r *apipb.Record) *netpb.Log_Record
Types ¶
type Semaphore ¶ added in v1.0.0
type Semaphore struct {
// contains filtered or unexported fields
}
func NewSemaphore ¶ added in v1.0.0
func (*Semaphore) TryAcquire ¶ added in v1.0.0
Non-blocking acquire
type SemaphoreKey ¶ added in v1.0.0
type SemaphoreKey interface {
Key() string
}
type SemaphorePool ¶ added in v1.0.0
type SemaphorePool struct {
// contains filtered or unexported fields
}
func NewSemaphorePool ¶ added in v1.0.0
func NewSemaphorePool(semaCap int) *SemaphorePool
func (*SemaphorePool) Get ¶ added in v1.0.0
func (p *SemaphorePool) Get(k SemaphoreKey) *Semaphore
func (*SemaphorePool) Stop ¶ added in v1.0.0
func (p *SemaphorePool) Stop()
Click to show internal directories.
Click to hide internal directories.