mysql_storage

Documentation

Index

• Constants
• type MysqlClient
  • func (m *MysqlClient) GetSagaById(ctx context.Context, id string) (*saga.SagaOrchestrator, error)
  • func (m *MysqlClient) SaveSaga(ctx context.Context) error
• type MysqlConfig
• type StorageClient
  • func NewStorageClient(conf MysqlConfig) (StorageClient, error)

Constants

const DefaultConnMaxLifeTime = time.Hour

const DefaultMaxIdleConn = 10

const DefaultMaxOpenConn = 10

Types

type MysqlClient

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

func (*MysqlClient) GetSagaById

func (m *MysqlClient) GetSagaById(ctx context.Context, id string) (*saga.SagaOrchestrator, error)

func (*MysqlClient) SaveSaga

func (m *MysqlClient) SaveSaga(ctx context.Context) error

type MysqlConfig

type MysqlConfig struct {
	Host   string
	DbName string
	User   string
	Pass   string
}

type StorageClient

type StorageClient interface {
}

func NewStorageClient

func NewStorageClient(conf MysqlConfig) (StorageClient, error)