mysqlpersister

package

v0.0.0-...-e20e094 Latest Latest Go to latest Published: Mar 3, 2022 License: Apache-2.0 Imports: 13 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

This section is empty.

View Source

var ErrDuplicateConfig = errors.New("config with provided version number already exists")

This section is empty.

type Connector interface {
	Connect() (*sql.DB, error)
}

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

func New(c Connector, pollingInterval time.Duration) (*MysqlPersister, error)

func (mp *MysqlPersister) Close()

Close closes the notification channel and the connection to MySQL.

func (mp *MysqlPersister) ConfigChangedWatcher() <-chan struct{}

ConfigChangedWatcher returns a channel that is notified whenever a new config is available.

func (mp *MysqlPersister) PersistAndNotify(_ string, c *qsc.ServiceConfig) error

PersistAndNotify persists a marshalled configuration passed in.

func (mp *MysqlPersister) ReadHistoricalConfigs() ([]*qsc.ServiceConfig, error)

ReadHistoricalConfigs returns an array of previously persisted configs

func (mp *MysqlPersister) ReadPersistedConfig() (*qsc.ServiceConfig, error)

ReadPersistedConfig provides a config previously persisted.

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

func NewUnsafeConnector(dbUser, dbPass, dbHost string, dbPort int, dbName string) *UnsafeConnector

func (c *UnsafeConnector) Connect() (*sql.DB, error)