rpc

package

v0.4.2 Latest Latest Go to latest Published: Mar 22, 2019 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thingful/iotstore

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Datastore
- func NewDatastore(db *postgres.DB, verbose bool, logger kitlog.Logger) *Datastore

Constants ¶

View Source

const (
	// DefaultPageSize is the default page size we use when reading data from the
	// datastore.
	DefaultPageSize = 500

	// MaxPageSize is the maximum page size we allow clients to request when
	// reading data from the datastore.
	MaxPageSize = 1000
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Datastore ¶

type Datastore struct {
	DB *postgres.DB
	// contains filtered or unexported fields
}

Datastore is our implementation of the generated twirp interface for the encrypted datastore.

func NewDatastore ¶

func NewDatastore(db *postgres.DB, verbose bool, logger kitlog.Logger) *Datastore

NewDatastore returns a newly instantiated Datastore instance. It takes as parameters a DB connection string and a logger. The connection string is passed down to the postgres package where it is used to connect.

func (*Datastore) ReadData ¶

func (d *Datastore) ReadData(ctx context.Context, req *datastore.ReadRequest) (*datastore.ReadResponse, error)

ReadData is the handler that allows a client to request data from the datastore matching search parameters defined in the incoming datastore.ReadRequest object.

func (*Datastore) Start ¶

func (d *Datastore) Start() error

Start starts all child components (here just the postgres DB).

func (*Datastore) Stop ¶

func (d *Datastore) Stop() error

Stop stops all child components.

func (*Datastore) WriteData ¶

func (d *Datastore) WriteData(ctx context.Context, req *datastore.WriteRequest) (*datastore.WriteResponse, error)

WriteData is the method by which data is written into the datastore. It accepts a context, and a WriteRequest object containing the data. Provided the incoming request object is valid, then an event will be written into the database. Any invalid data will return an error.

Source Files ¶

View all Source files

datastore.go

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