activity

Aug 26, 2023

Changes in this version

+ const NetworkActivityMimeType

+ var ErrInvalidWindow = errors.New("aggregation window must be greater than 0")

+ var ErrMissingTopic = errors.New("missing activity topic")

+ var ErrUnknownNetwork = errors.New("unknown network, expected testnet, mainnet, or rvasp")

+ var NetworkActivityEventType = api.Type

+ func Reset()

+ func SetClient(newClient *ensign.Client)

+ func Start(conf Config) (err error)

+ func Stop()

+ type Activity uint16

+ const KeyExchangeActivity

+ const LookupActivity

+ const RegisterActivity

+ const SearchActivity

+ const UnknownActivity

+ func (a Activity) String() string

+ type ActivityCount map[Activity]uint64

+ type Config struct

+ AggregationWindow time.Duration

+ Enabled bool

+ Ensign ensign.Config

+ Network Network

+ Testing bool

+ Topic string

+ func (c Config) Validate() (err error)

+ type Entry struct

+ func KeyExchange() *Entry

+ func Lookup() *Entry

+ func Register() *Entry

+ func Search() *Entry

+ func (e *Entry) Add()

+ func (e *Entry) VASP(id string) *Entry

+ type Network uint8

+ const MainNet

+ const RVASP

+ const TestNet

+ const UnknownNetwork

+ func (n *Network) Decode(s string) error

+ func (n Network) String() string

+ func (n Network) Validate() error

+ type NetworkActivity struct

+ Activity ActivityCount

+ Network Network

+ Timestamp time.Time

+ VASPActivity map[string]ActivityCount

+ Window time.Duration

+ func New(network Network, window time.Duration, ts time.Time) *NetworkActivity

+ func Parse(event *ensign.Event) (_ *NetworkActivity, err error)

+ func (a *NetworkActivity) Event() (_ *ensign.Event, err error)

+ func (a *NetworkActivity) Incr(activity Activity)

+ func (a *NetworkActivity) IncrVASP(vaspID string, activity Activity)

+ func (a *NetworkActivity) Reset()

+ func (a *NetworkActivity) WindowEnd() time.Time

+ func (a *NetworkActivity) WindowStart() time.Time