sessions

Documentation

Index

• func New(id string, logger *zap.Logger) *server
• type Channel
• type SessionStore
  • func NewSessionStore(mesh types.GossipServiceLayer, logger *zap.Logger) SessionStore

Functions

func New

func New(id string, logger *zap.Logger) *server

Types

type Channel

type Channel interface {
	Broadcast([]byte)
}

type SessionStore

type SessionStore interface {
	ByID(id string) (*pb.Session, error)
	ByClientID(id string) (*pb.SessionMetadataList, error)
	ByPeer(peer string) (*pb.SessionMetadataList, error)
	All(*pb.SessionFilterInput) (*pb.SessionMetadataList, error)
	Exists(id string) bool
	Delete(id string) error
	Create(sess *pb.Session) error
	Update(id string, op func(pb.Session) *pb.Session) error
}

func NewSessionStore

func NewSessionStore(mesh types.GossipServiceLayer, logger *zap.Logger) SessionStore