Versions in this module Expand all Collapse all v0 v0.0.1 Oct 3, 2023 Changes in this version + const LatestVersion + 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 struct + func NewStubDBStore(ctx context.Context, config *config.MySQLConfig) (*StubDBStore, error) + func (s *StubDBStore) Create(ctx context.Context, stubs ...*rio.Stub) error + func (s *StubDBStore) CreateIncomingRequest(ctx context.Context, r *rio.IncomingRequest) error + func (s *StubDBStore) CreateProto(ctx context.Context, protos ...*rio.Proto) error + func (s *StubDBStore) Delete(ctx context.Context, id int64) error + func (s *StubDBStore) Find(ctx context.Context, id int64) (*rio.Stub, error) + func (s *StubDBStore) GetAll(ctx context.Context, namespace string) ([]*rio.Stub, error) + func (s *StubDBStore) GetIncomingRequests(ctx context.Context, option *rio.IncomingQueryOption) ([]*rio.IncomingRequest, error) + func (s *StubDBStore) GetLastUpdatedProto(ctx context.Context) (*rio.LastUpdatedRecord, error) + func (s *StubDBStore) GetLastUpdatedStub(ctx context.Context, namespace string) (*rio.LastUpdatedRecord, error) + func (s *StubDBStore) GetProtos(ctx context.Context) ([]*rio.Proto, error) + func (s *StubDBStore) Reset(ctx context.Context, option *rio.ResetQueryOption) error