connection

type ClientStatus struct {
	PushQueued    bool
	PushingStatus PushingStatus

	NonceInc int64

	ClientVersion *VersionedRule

	LastPushedTime    int64
	LastPushedVersion *VersionedRule
	LastPushNonce     string
}

type Connection struct {
	EndpointConnection EndpointConnection
	Endpoint           *rule.Endpoint

	TypeListened map[string]bool

	RawRuleQueue  workqueue.Interface
	ExpectedRules map[string]*VersionedRule
	ClientRules   map[string]*ClientStatus
	// contains filtered or unexported fields
}

type ConnectionStatus int

type EndpointConnection interface {
	Send(*ObserveResponse) error
	Recv() (*ObserveRequest, error)
	Disconnect()
}

type ObserveRequest struct {
	Nonce string
	Type  string
}

type ObserveResponse struct {
	Nonce string
	Type  string
	Data  rule.ToClient
}

type PushingStatus int

type Storage struct {
	Mutex      *sync.RWMutex
	Connection []*Connection

	LatestRules map[string]rule.Origin
}

type VersionedRule struct {
	Revision int64
	Type     string
	Data     rule.ToClient
}