sessions

Documentation

Index

• type BackconnectSession
  • func NewBackconnection(conn net.Conn) *BackconnectSession
  • func (session *BackconnectSession) Connect(a asyncrw.AsyncSenderReciever) error
  • func (session *BackconnectSession) Kill()
  • func (session *BackconnectSession) Run()
• type Subscription
  • func NewSubscription(stream pb.Backconnectd_SubscribeServer) *Subscription
  • func (ci *Subscription) ID() uuid.UUID
  • func (s *Subscription) Run()
  • func (ci *Subscription) SendEvent(evt *pb.SessionEvent)

Types

type BackconnectSession

type BackconnectSession struct {
	sessioninfo.SessionInfo
	// contains filtered or unexported fields
}

func NewBackconnection

func NewBackconnection(conn net.Conn) *BackconnectSession

func (*BackconnectSession) Connect

func (session *BackconnectSession) Connect(a asyncrw.AsyncSenderReciever) error

func (*BackconnectSession) Kill

func (session *BackconnectSession) Kill()

func (*BackconnectSession) Run

func (session *BackconnectSession) Run()

type Subscription

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

func NewSubscription

func NewSubscription(stream pb.Backconnectd_SubscribeServer) *Subscription

func (*Subscription) ID

func (ci *Subscription) ID() uuid.UUID

func (*Subscription) Run

func (s *Subscription) Run()

func (*Subscription) SendEvent

func (ci *Subscription) SendEvent(evt *pb.SessionEvent)