migration

package

v0.10.53 Latest Latest Go to latest Published: Mar 22, 2024 License: MIT Imports: 9 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/pericles-luz/go-base

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CreateTableSQLite(db *sql.DB) error
func GenerateTestData(db *sql.DB) error
func GetDB() *sql.DB
func GetPool(db *sql.DB) *database.Pool
func SetupTest(t *testing.T) (func(t *testing.T), *database.Pool)
type Message
- func NewMessage() *Message
type MessageDB
- func NewMessageDB(db *sql.DB) *MessageDB
type MessageService
- func NewMessageService(persistence *MessageDB) *MessageService

Constants ¶

View Source

const (
	EXCHANGE_NOT_INFORMED    = "exchange not informed"
	ROUTING_KEY_NOT_INFORMED = "routing key not informed"
	DATA_NOT_INFORMED        = "data not informed"
)

View Source

const (
	STATUS_PENDING = 0
	STATUS_SENDING = 1
)

View Source

const (
	DATABASE_GENERAL   = "general"
	DATABASE_FINANCE   = "finance"
	DATABASE_MESSAGING = "messaging"
)

Variables ¶

This section is empty.

Functions ¶

func CreateTableSQLite ¶

func CreateTableSQLite(db *sql.DB) error

func GenerateTestData ¶

func GenerateTestData(db *sql.DB) error

func GetDB ¶

func GetDB() *sql.DB

func GetPool ¶

func GetPool(db *sql.DB) *database.Pool

func SetupTest ¶

func SetupTest(t *testing.T) (func(t *testing.T), *database.Pool)

Types ¶

type Message ¶

type Message struct {
	RabbitCacheID string `json:"id"`
	DE_Exchange   string `json:"exchange" validate:"required"`
	DE_RoutingKey string `json:"routingKey" validate:"required"`
	JS_Data       string `json:"data" validate:"required"`
	SN_Durable    int16  `json:"durable" validate:"required"`
	TS_Operacao   time.Time
}

func NewMessage ¶

func NewMessage() *Message

func (*Message) GetData ¶

func (m *Message) GetData() string

func (*Message) GetDurable ¶

func (m *Message) GetDurable() int16

func (*Message) GetExchange ¶

func (m *Message) GetExchange() string

func (*Message) GetID ¶

func (m *Message) GetID() string

func (*Message) GetRoutingKey ¶

func (m *Message) GetRoutingKey() string

func (*Message) IsValid ¶

func (m *Message) IsValid() error

func (*Message) SetData ¶

func (m *Message) SetData(data interface{})

func (*Message) SetDurable ¶

func (m *Message) SetDurable(durable int16)

func (*Message) SetExchange ¶

func (m *Message) SetExchange(exchange string)

func (*Message) SetID ¶

func (m *Message) SetID(id string)

func (*Message) SetRoutingKey ¶

func (m *Message) SetRoutingKey(routingKey string)

type MessageDB ¶

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

func NewMessageDB ¶

func NewMessageDB(db *sql.DB) *MessageDB

func (*MessageDB) Delete ¶

func (p *MessageDB) Delete(id string) error

func (*MessageDB) Get ¶

func (p *MessageDB) Get(id string) (*Message, error)

func (*MessageDB) GetNext ¶

func (p *MessageDB) GetNext() (*Message, error)

func (*MessageDB) Save ¶

func (p *MessageDB) Save(message *Message) error

func (*MessageDB) SetStatus ¶

func (m *MessageDB) SetStatus(id string, status int) error

type MessageService ¶

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

func NewMessageService ¶

func NewMessageService(persistence *MessageDB) *MessageService

func (*MessageService) Create ¶

func (s *MessageService) Create(exchange string, routingKey string, data string, durable int16) (*Message, error)

func (*MessageService) Delete ¶

func (s *MessageService) Delete(id string) error

func (*MessageService) Get ¶

func (s *MessageService) Get(id string) (*Message, error)

func (*MessageService) GetNext ¶

func (s *MessageService) GetNext() (*Message, error)

func (*MessageService) Send ¶

func (s *MessageService) Send(exchange string, routingKey string, data string, durable int16) (*Message, error)

Source Files ¶

View all Source files

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