database

package

v1.2.4 Latest Latest Go to latest Published: Jul 8, 2023 License: Apache-2.0 Imports: 16 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/hungdv136/rio

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Connect(ctx context.Context, config *config.MySQLConfig) (*gorm.DB, error)
func Disconnect(ctx context.Context, db *gorm.DB) error
func ExecuteFileScript(ctx context.Context, db *gorm.DB, filePath string) error
func Migrate(ctx context.Context, config *config.MySQLConfig, dir string) error
type StubDBStore
- func NewStubDBStore(ctx context.Context, config *config.MySQLConfig) (*StubDBStore, error)

Constants ¶

View Source

const LatestVersion = 3

The stub schema version

Variables ¶

This section is empty.

Functions ¶

func Connect ¶

func Connect(ctx context.Context, config *config.MySQLConfig) (*gorm.DB, error)

Connect setups connections to MySQL database

func Disconnect ¶

func Disconnect(ctx context.Context, db *gorm.DB) error

Disconnect closes the connections to the MySQL database

func ExecuteFileScript ¶

func ExecuteFileScript(ctx context.Context, db *gorm.DB, filePath string) error

ExecuteFileScript runs a specific migration file on a MySQL database using specific path

func Migrate ¶

func Migrate(ctx context.Context, config *config.MySQLConfig, dir string) error

Types ¶

type StubDBStore ¶

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

StubDBStore stores stub information to database

func NewStubDBStore ¶

func NewStubDBStore(ctx context.Context, config *config.MySQLConfig) (*StubDBStore, error)

NewStubDBStore init a new instance for storage

func (*StubDBStore) Create ¶

func (s *StubDBStore) Create(ctx context.Context, stubs ...*rio.Stub) error

Create creates a new stub

func (*StubDBStore) CreateIncomingRequest ¶

func (s *StubDBStore) CreateIncomingRequest(ctx context.Context, r *rio.IncomingRequest) error

CreateIncomingRequest saves the income request

func (*StubDBStore) CreateProto ¶

func (s *StubDBStore) CreateProto(ctx context.Context, protos ...*rio.Proto) error

CreateProto creates new protos

func (*StubDBStore) Delete ¶

func (s *StubDBStore) Delete(ctx context.Context, id int64) error

Delete marks record as inactive

func (*StubDBStore) Find ¶

func (s *StubDBStore) Find(ctx context.Context, id int64) (*rio.Stub, error)

Find finds by id

func (*StubDBStore) GetAll ¶

func (s *StubDBStore) GetAll(ctx context.Context, namespace string) ([]*rio.Stub, error)

GetAll gets all saved records

func (*StubDBStore) GetIncomingRequests ¶

func (s *StubDBStore) GetIncomingRequests(ctx context.Context, option *rio.IncomingQueryOption) ([]*rio.IncomingRequest, error)

GetIncomingRequests finds a income request by id

func (*StubDBStore) GetLastUpdatedProto ¶

func (s *StubDBStore) GetLastUpdatedProto(ctx context.Context) (*rio.LastUpdatedRecord, error)

func (*StubDBStore) GetLastUpdatedStub ¶

func (s *StubDBStore) GetLastUpdatedStub(ctx context.Context, namespace string) (*rio.LastUpdatedRecord, error)

func (*StubDBStore) GetProtos ¶

func (s *StubDBStore) GetProtos(ctx context.Context) ([]*rio.Proto, error)

GetProtos gets a list of protos

func (*StubDBStore) Reset ¶

func (s *StubDBStore) Reset(ctx context.Context, option *rio.ResetQueryOption) error

Reset clear data

Source Files ¶

View all Source files

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