mysql

Documentation

Index

• type MySQL
  • func NewMySQLStateStore(logger logger.Logger) *MySQL
  • func (m *MySQL) BulkDelete(req []state.DeleteRequest) error
  • func (m *MySQL) BulkGet(req []state.GetRequest) (bool, []state.BulkGetResponse, error)
  • func (m *MySQL) BulkSet(req []state.SetRequest) error
  • func (m *MySQL) Close() error
  • func (m *MySQL) Delete(req *state.DeleteRequest) error
  • func (m *MySQL) Features() []state.Feature
  • func (m *MySQL) Get(req *state.GetRequest) (*state.GetResponse, error)
  • func (m *MySQL) Init(metadata state.Metadata) error
  • func (m *MySQL) Multi(request *state.TransactionalStateRequest) error
  • func (m *MySQL) Set(req *state.SetRequest) error

Types

type MySQL

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

MySQL state store

func NewMySQLStateStore

func NewMySQLStateStore(logger logger.Logger) *MySQL

NewMySQLStateStore creates a new instance of MySQL state store

func (*MySQL) BulkDelete

func (m *MySQL) BulkDelete(req []state.DeleteRequest) error

BulkDelete removes multiple entries from the store Store Interface

func (*MySQL) BulkGet

func (m *MySQL) BulkGet(req []state.GetRequest) (bool, []state.BulkGetResponse, error)

BulkGet performs a bulks get operations

func (*MySQL) BulkSet

func (m *MySQL) BulkSet(req []state.SetRequest) error

BulkSet adds/updates multiple entities on store Store Interface

func (*MySQL) Close

func (m *MySQL) Close() error

Close implements io.Closer

func (*MySQL) Delete

func (m *MySQL) Delete(req *state.DeleteRequest) error

Delete removes an entity from the store Store Interface

func (*MySQL) Features

func (m *MySQL) Features() []state.Feature

Features returns the features available in this state store

func (*MySQL) Get

func (m *MySQL) Get(req *state.GetRequest) (*state.GetResponse, error)

Get returns an entity from store Store Interface

func (*MySQL) Init

func (m *MySQL) Init(metadata state.Metadata) error

Init initializes the SQL server state store Implements the following interfaces: Store TransactionalStore Populate the rest of the MySQL object by reading the metadata and opening a connection to the server.

func (*MySQL) Multi

func (m *MySQL) Multi(request *state.TransactionalStateRequest) error

Multi handles multiple transactions. TransactionalStore Interface

func (*MySQL) Set

func (m *MySQL) Set(req *state.SetRequest) error

Set adds/updates an entity on store Store Interface