dbr_sync

package module

v0.0.0-...-220ef87 Latest Latest Go to latest Published: Mar 20, 2024 License: MIT 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/joaosoft/dbr-sync

Links

Open Source Insights

README ¶

dbr-sync

| | |

A service to sync data between databases.

If i miss something or you have something interesting, please be part of this project. Let me know! My contact is at the end.

Dependecy Management

Dependency

Project dependencies are managed using Dep. Read more about Dep.

Get dependency manager: go get github.com/joaosoft/dependency
Install dependencies: dependency get

Go

go get github.com/joaosoft/dbr-sync

Known issues

Follow me at

Facebook: https://www.facebook.com/joaosoft

LinkedIn: https://www.linkedin.com/in/jo%C3%A3o-ribeiro-b2775438/

If you have something to add, please let me know joaosoft@gmail.com

Documentation ¶

Index ¶

Constants
Variables
func EncodeString(s string) string
func Exists(file string) bool
func GetEnv() string
func ReadFile(file string, obj interface{}) ([]byte, error)
func ReadFileLines(file string) ([]string, error)
func WriteFile(file string, obj interface{}) error
type AppConfig
- func NewConfig() (*AppConfig, manager.IConfig, error)
type DbrSync
- func NewDbrSync(options ...DbrSyncOption) (*DbrSync, error)
- func (dbrSync *DbrSync) Reconfigure(options ...DbrSyncOption)
- func (m *DbrSync) Start() error
- func (m *DbrSync) Stop() error
type DbrSyncConfig
type DbrSyncOption
- func WithConfiguration(config *DbrSyncConfig) DbrSyncOption
- func WithLogLevel(level logger.Level) DbrSyncOption
- func WithLogger(logger logger.ILogger) DbrSyncOption
- func WithManager(mgr *manager.Manager) DbrSyncOption
type Details
type Operation
type OperationList
type RabbitmqConfig

Constants ¶

View Source

const (
	ModeDetails mode = "details"
	ModeQuery   mode = "query"
)

Variables ¶

View Source

var (
	ErrorNotFound    = errors.New(errors.LevelError, int(web.StatusNotFound), "user not found")
	ErrorInvalidType = errors.New(errors.LevelError, int(web.StatusNotFound), "invalid type")
)

Functions ¶

func EncodeString ¶

func EncodeString(s string) string

func Exists ¶

func Exists(file string) bool

func GetEnv ¶

func GetEnv() string

func ReadFile ¶

func ReadFile(file string, obj interface{}) ([]byte, error)

func ReadFileLines ¶

func ReadFileLines(file string) ([]string, error)

func WriteFile ¶

func WriteFile(file string, obj interface{}) error

Types ¶

type AppConfig ¶

type AppConfig struct {
	DbrSync *DbrSyncConfig `json:"dbr-sync"`
}

AppConfig ...

func NewConfig ¶

func NewConfig() (*AppConfig, manager.IConfig, error)

NewConfig ...

type DbrSync ¶

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

func NewDbrSync ¶

func NewDbrSync(options ...DbrSyncOption) (*DbrSync, error)

NewDbrSync ...

func (*DbrSync) Reconfigure ¶

func (dbrSync *DbrSync) Reconfigure(options ...DbrSyncOption)

Reconfigure ...

func (*DbrSync) Start ¶

func (m *DbrSync) Start() error

Start ...

func (*DbrSync) Stop ¶

func (m *DbrSync) Stop() error

Stop ...

type DbrSyncConfig ¶

type DbrSyncConfig struct {
	Rabbitmq  RabbitmqConfig             `json:"rabbitmq"`
	Dbr       *dbr.DbrConfig             `json:"dbr"`
	Migration *migration.MigrationConfig `json:"migration"`
	Mode      mode                       `json:"mode"`
	Log       struct {
		Level string `json:"level"`
	} `json:"log"`
}

ProfileConfig ...

type DbrSyncOption ¶

type DbrSyncOption func(dbrSync *DbrSync)

DbrSyncOption ...

func WithConfiguration ¶

func WithConfiguration(config *DbrSyncConfig) DbrSyncOption

WithConfiguration ...

func WithLogLevel ¶

func WithLogLevel(level logger.Level) DbrSyncOption

WithLogLevel ...

func WithLogger ¶

func WithLogger(logger logger.ILogger) DbrSyncOption

WithLogger ...

func WithManager ¶

func WithManager(mgr *manager.Manager) DbrSyncOption

WithManager ...

type Details ¶

type Details struct {
	Table      string                 `json:"table"`
	Values     map[string]interface{} `json:"values"`
	Conditions map[string]interface{} `json:"conditions"`
}

type Operation ¶

type Operation struct {
	Operation dbr.SqlOperation `json:"operation"`
	Query     *string          `json:"query"`
	Details   *Details         `json:"details"`
}

type OperationList ¶

type OperationList []*Operation

type RabbitmqConfig ¶

type RabbitmqConfig struct {
	*manager.RabbitmqConfig
	Queue   string `json:"queue"`
	Binding string `json:"binding"`
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
examples

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