connman

Documentation

Index

• Variables
• type ConnectionManager
  • func New() *ConnectionManager
  • func (m *ConnectionManager) Dial(ctx context.Context, key string) (net.Conn, error)
  • func (m *ConnectionManager) Set(key string, conn *wsconnadapter.Adapter, connPath string)
• type SyncSliceMap
  • func (ssm *SyncSliceMap) Delete(key, value interface{})
  • func (ssm *SyncSliceMap) Load(key interface{}) (interface{}, bool)
  • func (ssm *SyncSliceMap) Size(key interface{}) int
  • func (ssm *SyncSliceMap) Store(key, value interface{})

Variables

var ErrNoConnection = errors.New("no connection")

Types

type ConnectionManager

type ConnectionManager struct {
	DialerDoneCallback      func(string, *revdial.Dialer)
	DialerKeepAliveCallback func(string, *revdial.Dialer)
	// contains filtered or unexported fields
}

func New

func New() *ConnectionManager

func (*ConnectionManager) Dial

func (m *ConnectionManager) Dial(ctx context.Context, key string) (net.Conn, error)

func (*ConnectionManager) Set

func (m *ConnectionManager) Set(key string, conn *wsconnadapter.Adapter, connPath string)

type SyncSliceMap

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

SyncSliceMap is a struct that uses sync.Map and stores values in a slice.

func (*SyncSliceMap) Delete

func (ssm *SyncSliceMap) Delete(key, value interface{})

Delete removes the value from the slice associated with the key and updates the value in sync.Map.

func (*SyncSliceMap) Load

func (ssm *SyncSliceMap) Load(key interface{}) (interface{}, bool)

Load retrieves the last value associated with the key in the slice along with the size of the slice.

func (*SyncSliceMap) Size

func (ssm *SyncSliceMap) Size(key interface{}) int

Size returns the current size of the slice associated with the key.

func (*SyncSliceMap) Store

func (ssm *SyncSliceMap) Store(key, value interface{})

Store appends the value to the slice associated with the key and updates the value in sync.Map. It returns the size of the slice after the append operation.