base

type ClientInfo struct {
	UserName     string
	CleanSession bool
	PeerName     string
	ConnectTime  string
}

type DecodeFeedback interface {
	// SetTruncated should be called if during decoding you notice that
	// a packet is shorter than internal layer variables
	SetTruncated()
}

type HubNodeInfo struct {
	NodeName  string
	NodeIp    string
	CreatedAt string
}

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

type NilDecodeFeedback struct{}

type Packet interface {
	// PacketType return type name of packet
	PacketType() string

	// DecodeFromReader decode packet from given reader
	DecodeFromReader(r io.Reader, df DecodeFeedback) error

	// DecodeFromBytes decode packet from given
	DecodeFromBytes(data []uint8, df DecodeFeedback) error

	// SerializeTo writes the serialized form of the packet into the serialize buffer
	SerializeTo(buf SerializeBuffer, opts SerializeOptions) error

	// Clear clear packet content and payload
	Clear()

	// Length return length of the packet
	Length() int
}

type ProtocolService interface {
	// Service Infomation
	GetServiceInfo() *ServiceInfo

	// Stats and Metrics
	GetStats() *Stats
	GetMetrics() *Metrics

	// Client
	GetClients() []*ClientInfo
	GetClient(id string) *ClientInfo
	KickoffClient(id string) error

	// Session
	GetSessions(conditions map[string]bool) []*SessionInfo
	GetSession(id string) *SessionInfo

	// Route info
	GetRoutes() []*RouteInfo
	GetRoute(id string) *RouteInfo

	// Topic info
	GetTopics() []*TopicInfo
	GetTopic(id string) *TopicInfo

	// SubscriptionInfo
	GetSubscriptions() []*SubscriptionInfo
	GetSubscription(id string) *SubscriptionInfo
}

type RouteInfo struct {
	Topic string
	Route []string
}

type SerializeBuffer interface {
	// Bytes return the continguous set of bytes
	Bytes() []byte
	// PrependBytes return a set of bytes which prepends the curent bytes
	// in this buffer
	PrependBytes(num int) ([]byte, error)
	// AppendBytes return a set of bytes which append the current bytes
	// in this buffer
	AppendBytes(num int) ([]byte, error)
	// Clear reset the SerializeBuffer to a new
	Clear() error
}

type SerializeOptions struct {
	// Fixlengths determines whether layers should fix the values for any
	// length field that depends on the payload during serialization
	FixLengths bool
	// ComputeChecksums determines wethers layers should recompute checksums
	// based on their payloads
	ComputeChecksums bool
}

type Service interface {
	Info() *ServiceInfo
	Start() error
	Stop()
}

type ServiceCommand int

type ServiceFactory interface {
	New(name string, c core.Config, ch chan ServiceCommand) (Service, error)
}

type ServiceInfo struct {
	ServiceName    string
	Listen         string
	Acceptors      uint64
	MaxClients     uint64
	CurrentClients uint64
	ShutdownCount  uint64
}

type ServiceManager struct {
	sync.Once
	// contains filtered or unexported fields
}

type Session interface {
	// Identifier get session identifier
	Identifier() string
	// Info return session information
	Info() *SessionInfo
	// GetService get the service ower for current session
	Service() Service
	// Handle indicate service to handle the packet
	Handle() error
	// Destroy will release current session
	Destroy() error
	// RegisterObserver register observer on session
	RegisterObserver(SessionObserver)
	// Get Stats
	GetStats() *Stats
	// Get Metrics
	GetMetrics() *Metrics
}

type SessionInfo struct {
	ClientId           string
	CleanSession       bool
	MessageMaxInflight uint64
	MessageInflight    uint64
	MessageInQueue     uint64
	MessageDropped     uint64
	AwaitingRel        uint64
	AwaitingComp       uint64
	AwaitingAck        uint64
	CreatedAt          string
}

type SessionObserver interface {
	OnGetMountPoint() string
	OnConnect(s Session, userdata interface{}) error
	OnDisconnect(s Session, userdta interface{}) error
	OnPublish(s Session, userdata interface{}) error
	OnMessage(s Session, userdata interface{}) error
	OnSubscribe(s Session, userdata interface{}) error
	OnUnsubscribe(s Session, userdata interface{}) error
	OnAuthenticate(s Session, username string, password string) error
}

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

type SubscriptionInfo struct {
	ClientId  string
	Topic     string
	Attribute string
}

type TopicInfo struct {
	Topic     string
	Attribute string
}