backend

Documentation

Index

• Variables
• func Each(i Iterator, fn func(interface{}) error) error
• func EachChannel(i Iterator) chan interface{}
• func NewBackendContext(ctx context.Context, b Backend) context.Context
• type Backend
  • func BackendFromContext(ctx context.Context) (Backend, error)
• type IdentityMap
  • func NewIdentityMap(b Backend) *IdentityMap
  • func (m *IdentityMap) FindID(objectType string, id interface{}) (interface{}, error)
• type Iterator
• type MongoDBBackend
  • func NewMongoDBBackend(addrs []string, database, username, password string, ssl bool) (*MongoDBBackend, error)
  • func (m *MongoDBBackend) Close() error
  • func (m *MongoDBBackend) Find(objectType string, query map[string]interface{}) (Iterator, error)
  • func (m *MongoDBBackend) FindID(objectType string, id interface{}) (interface{}, error)
  • func (m *MongoDBBackend) Upsert(objectType string, query map[string]interface{}, object interface{}) error
  • func (m *MongoDBBackend) UpsertID(objectType string, id, object interface{}) error

Variables

var (
	ErrBackendNotInitializedError = errors.New("backend not initialized")
	ErrBackendType                = errors.New("object type is incorrect")
)

Functions

func Each

func Each(i Iterator, fn func(interface{}) error) error

func EachChannel

func EachChannel(i Iterator) chan interface{}

func NewBackendContext

func NewBackendContext(ctx context.Context, b Backend) context.Context

Types

type Backend

type Backend interface {
	Find(objectType string, query map[string]interface{}) (Iterator, error)
	FindID(objectType string, id interface{}) (interface{}, error)
	Upsert(objectType string, query map[string]interface{}, object interface{}) error
	UpsertID(objectType string, id, object interface{}) error
	Close() error
}

func BackendFromContext

func BackendFromContext(ctx context.Context) (Backend, error)

type IdentityMap

type IdentityMap struct {
	Backend
	// contains filtered or unexported fields
}

func NewIdentityMap

func NewIdentityMap(b Backend) *IdentityMap

func (*IdentityMap) FindID

func (m *IdentityMap) FindID(objectType string, id interface{}) (interface{}, error)

type Iterator

type Iterator interface {
	Next() (value interface{}, done bool, err error)
}

type MongoDBBackend

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

MongoDBBackend represents a MongoDB backend.

func NewMongoDBBackend

func NewMongoDBBackend(addrs []string, database, username, password string, ssl bool) (*MongoDBBackend, error)

NewMongoDBBackend creates a new MongoDBBackendBackend object using a MongoDB conection string. Any database defined in the connection string will be overridden by the argument-specified database.

func (*MongoDBBackend) Close

func (m *MongoDBBackend) Close() error

Close closes the underlying session.

func (*MongoDBBackend) Find

func (m *MongoDBBackend) Find(objectType string, query map[string]interface{}) (Iterator, error)

func (*MongoDBBackend) FindID

func (m *MongoDBBackend) FindID(objectType string, id interface{}) (interface{}, error)

func (*MongoDBBackend) Upsert

func (m *MongoDBBackend) Upsert(objectType string, query map[string]interface{}, object interface{}) error

func (*MongoDBBackend) UpsertID

func (m *MongoDBBackend) UpsertID(objectType string, id, object interface{}) error