datastores

Documentation

Index

• type AuthDatastore
  • func NewAuthInstance(db *sql.DB) *AuthDatastore
  • func (d *AuthDatastore) IsTokenAuthorized(token string) (bool, error)
• type StorageDatastore
  • func NewStorageInstance(cluster *gocql.ClusterConfig) (*StorageDatastore, error)
  • func (d *StorageDatastore) Close()
  • func (d *StorageDatastore) StoreBatchEvents(p *models.EventTrackingPayload) error

Types

type AuthDatastore

type AuthDatastore struct {
	sql.DB
}

AuthDatastore represents a wrapper around sql.DB

func NewAuthInstance

func NewAuthInstance(db *sql.DB) *AuthDatastore

NewAuthInstance returns a wrapped db connection

func (*AuthDatastore) IsTokenAuthorized

func (d *AuthDatastore) IsTokenAuthorized(token string) (bool, error)

IsTokenAuthorized checks wheter a token is valid or not

type StorageDatastore

type StorageDatastore struct {
	*gocql.Session
}

StorageDatastore wraps a gocql.Session

func NewStorageInstance

func NewStorageInstance(cluster *gocql.ClusterConfig) (*StorageDatastore, error)

NewStorageInstance returns a new StorageDatastore containing a connection to the specified cluster

func (*StorageDatastore) Close

func (d *StorageDatastore) Close()

Close closes the internal gocql.Session instance

func (*StorageDatastore) StoreBatchEvents

func (d *StorageDatastore) StoreBatchEvents(p *models.EventTrackingPayload) error

StoreBatchEvents stores multiple events from models.EventTrackingPayload within a batch