utils

package
v0.0.0-...-36dbddc Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 30, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExecuteQuery

func ExecuteQuery(query string, session *gocql.Session) error

ExecuteQuery executes a query and returns an error if any

func GetSession

func GetSession(cosmosCassandraContactPoint, cosmosCassandraPort, cosmosCassandraUser, cosmosCassandraPassword string) *gocql.Session

GetSession connects to Cassandra

Types

type Timer

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

func CreateTimer

func CreateTimer() Timer

func (Timer) Duration

func (t Timer) Duration() time.Duration

func (Timer) ObserveQuery

func (t Timer) ObserveQuery(ctx context.Context, oq gocql.ObservedQuery)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL