anonmetrics

Documentation

Index

• Constants
• func MakeMigration(d *sql.DB, migrationResource *bindata.AssetSource) (*migrate.Migrate, error)
• func NewMigratedDB(uri string, migrationResource *bindata.AssetSource) (*sql.DB, error)
• type Client
  • func NewClient(sender *common.MessageSender) *Client
  • func (c *Client) Start() error
  • func (c *Client) Stop() error
• type ClientConfig
• type FibonacciIntervalIncrementer
  • func (f *FibonacciIntervalIncrementer) Next() int64
• type Server
  • func NewServer(postgresURI string) (*Server, error)
  • func (s *Server) GetAppMetrics(limit int, offset int) ([]appmetrics.AppMetric, error)
  • func (s *Server) Stop() error
  • func (s *Server) StoreMetrics(appMetricsBatch protobuf.AnonymousMetricBatch) (appMetrics []*appmetrics.AppMetric, err error)
• type ServerConfig

Constants

const ActiveClientPhrase = "yes i am wanting the activation of the anon metrics client, please thank you lots thank you"

const ActiveServerPhrase = "" /* 135-byte string literal not displayed */

Functions

func MakeMigration

func MakeMigration(d *sql.DB, migrationResource *bindata.AssetSource) (*migrate.Migrate, error)

func NewMigratedDB

func NewMigratedDB(uri string, migrationResource *bindata.AssetSource) (*sql.DB, error)

Types

type Client

type Client struct {
	Config   *ClientConfig
	DB       *appmetrics.Database
	Identity *ecdsa.PrivateKey
	Logger   *zap.Logger

	IntervalInc *FibonacciIntervalIncrementer

	// DBLock prevents deletion of DB items during mainloop
	DBLock sync.Mutex
	// contains filtered or unexported fields
}

func NewClient

func NewClient(sender *common.MessageSender) *Client

func (*Client) Start

func (c *Client) Start() error

func (*Client) Stop

func (c *Client) Stop() error

type ClientConfig

type ClientConfig struct {
	ShouldSend  bool
	SendAddress *ecdsa.PublicKey
	Active      string
}

type FibonacciIntervalIncrementer

type FibonacciIntervalIncrementer struct {
	Last    int64
	Current int64
}

func (*FibonacciIntervalIncrementer) Next

func (f *FibonacciIntervalIncrementer) Next() int64

type Server

type Server struct {
	Config     *ServerConfig
	Logger     *zap.Logger
	PostgresDB *sql.DB
}

func NewServer

func NewServer(postgresURI string) (*Server, error)

func (*Server) GetAppMetrics

func (s *Server) GetAppMetrics(limit int, offset int) ([]appmetrics.AppMetric, error)

func (*Server) Stop

func (s *Server) Stop() error

func (*Server) StoreMetrics

func (s *Server) StoreMetrics(appMetricsBatch protobuf.AnonymousMetricBatch) (appMetrics []*appmetrics.AppMetric, err error)

type ServerConfig

type ServerConfig struct {
	Enabled     bool
	PostgresURI string
	Active      string
}