migration

Jul 10, 2023

Changes in this version

+ const STATUS_PENDING

+ const STATUS_SENDING

type MessageDB

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

May 8, 2023

Changes in this version

+ const DATABASE_FINANCE

+ const DATABASE_GENERAL

+ const DATABASE_MESSAGING

+ const DATA_NOT_INFORMED

+ const EXCHANGE_NOT_INFORMED

+ const ROUTING_KEY_NOT_INFORMED

+ 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 struct

+ DE_Exchange string

+ DE_RoutingKey string

+ JS_Data string

+ RabbitCacheID string

+ SN_Durable int16

+ TS_Operacao time.Time

+ func NewMessage() *Message

+ func (m *Message) GetData() string

+ func (m *Message) GetDurable() int16

+ func (m *Message) GetExchange() string

+ func (m *Message) GetID() string

+ func (m *Message) GetRoutingKey() string

+ func (m *Message) IsValid() error

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

+ func (m *Message) SetDurable(durable int16)

+ func (m *Message) SetExchange(exchange string)

+ func (m *Message) SetID(id string)

+ func (m *Message) SetRoutingKey(routingKey string)

+ type MessageDB struct

+ func NewMessageDB(db *sql.DB) *MessageDB

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

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

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

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

+ type MessageService struct

+ func NewMessageService(persistence *MessageDB) *MessageService

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

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

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

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

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