session

Documentation

Index

• Constants
• type Manager
  • func NewManager(sessionTimeout time.Duration) *Manager
  • func (sm *Manager) HasAnyOpenSession() bool
  • func (sm *Manager) HasOpenSession(pid peer.ID) bool
  • func (sm *Manager) NumberOfSessions() int
  • func (sm *Manager) OpenSession(pid peer.ID, from, count uint32) *Session
  • func (sm *Manager) RemoveAllSessions()
  • func (sm *Manager) Sessions() []*Session
  • func (sm *Manager) SetExpiredSessionsAsUncompleted()
  • func (sm *Manager) SetSessionCompleted(sid int) *Session
  • func (sm *Manager) SetSessionUncompleted(sid int)
  • func (sm *Manager) Stats() Stats
  • func (sm *Manager) UpdateSessionLastActivity(sid int)
• type Session
  • func NewSession(id int, peerID peer.ID, from, count uint32) *Session
• type Stats
  • func (ss *Stats) String() string
• type Status

Constants

const (
	Open        = Status(0)
	Completed   = Status(2)
	Uncompleted = Status(1)
)

Types

type Manager

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

func NewManager

func NewManager(sessionTimeout time.Duration) *Manager

func (*Manager) HasAnyOpenSession

func (sm *Manager) HasAnyOpenSession() bool

func (*Manager) HasOpenSession

func (sm *Manager) HasOpenSession(pid peer.ID) bool

func (*Manager) NumberOfSessions

func (sm *Manager) NumberOfSessions() int

func (*Manager) OpenSession

func (sm *Manager) OpenSession(pid peer.ID, from, count uint32) *Session

func (*Manager) RemoveAllSessions

func (sm *Manager) RemoveAllSessions()

func (*Manager) Sessions

func (sm *Manager) Sessions() []*Session

func (*Manager) SetExpiredSessionsAsUncompleted

func (sm *Manager) SetExpiredSessionsAsUncompleted()

func (*Manager) SetSessionCompleted

func (sm *Manager) SetSessionCompleted(sid int) *Session

func (*Manager) SetSessionUncompleted

func (sm *Manager) SetSessionUncompleted(sid int)

func (*Manager) Stats

func (sm *Manager) Stats() Stats

func (*Manager) UpdateSessionLastActivity

func (sm *Manager) UpdateSessionLastActivity(sid int)

type Session

type Session struct {
	SessionID    int
	Status       Status
	PeerID       peer.ID
	From         uint32
	Count        uint32
	LastActivity time.Time
}

func NewSession

func NewSession(id int, peerID peer.ID, from, count uint32) *Session

type Stats

type Stats struct {
	Total       int
	Open        int
	Completed   int
	Uncompleted int
}

func (*Stats) String

func (ss *Stats) String() string

type Status

type Status int