ingestserver

Documentation

Index

• type ConnsMap
  • func (cm *ConnsMap) Add(c net.Conn) bool
  • func (cm *ConnsMap) CloseAll(shutdownDuration time.Duration)
  • func (cm *ConnsMap) Delete(c net.Conn)
  • func (cm *ConnsMap) Init(clientName string)

Types

type ConnsMap

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

ConnsMap is used for tracking active connections.

func (*ConnsMap) Add

func (cm *ConnsMap) Add(c net.Conn) bool

Add adds c to cm.

func (*ConnsMap) CloseAll

func (cm *ConnsMap) CloseAll(shutdownDuration time.Duration)

CloseAll gradually closes all the cm conns with during the given shutdownDuration.

If shutdownDuration <= 0, then all the connections are closed simultaneously.

func (*ConnsMap) Delete

func (cm *ConnsMap) Delete(c net.Conn)

Delete deletes c from cm.

func (*ConnsMap) Init

func (cm *ConnsMap) Init(clientName string)

Init initializes cm.