common

README

common

This directory is used to store common Data Structures.

Documentation

Index

• type NonBlockingChan
  • func NewNonBlockingChan(cap int) *NonBlockingChan
  • func (nbCh *NonBlockingChan) Recv() (interface{}, bool)
  • func (nbCh *NonBlockingChan) RecvWithDeadline(deadline time.Duration) (interface{}, bool)
  • func (nbCh *NonBlockingChan) Send(value interface{}) bool
  • func (nbCh *NonBlockingChan) SendWithDeadline(value interface{}, deadline time.Duration) bool

Types

type NonBlockingChan

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

NonBlockingChan will drop new values when full

func NewNonBlockingChan

func NewNonBlockingChan(cap int) *NonBlockingChan

NewNonBlockingChan create a new non-blocking chan

func (*NonBlockingChan) Recv

func (nbCh *NonBlockingChan) Recv() (interface{}, bool)

Recv value from chan

func (*NonBlockingChan) RecvWithDeadline

func (nbCh *NonBlockingChan) RecvWithDeadline(deadline time.Duration) (interface{}, bool)

RecvWithDeadline try to recv value in given duration, the value will be skipped if failed

func (*NonBlockingChan) Send

func (nbCh *NonBlockingChan) Send(value interface{}) bool

Send value into chan

func (*NonBlockingChan) SendWithDeadline

func (nbCh *NonBlockingChan) SendWithDeadline(value interface{}, deadline time.Duration) bool

SendWithDeadline try to send value in given duration, the value will be dropped if failed