importer

Documentation

Index

• func Apply(c *fiber.Ctx) error
• func Import(c *fiber.Ctx, broker string) (*transaction.Transactions, error)
• type ImportSession
  • func NewImportSession(c *fiber.Ctx) (*ImportSession, error)
  • func (is *ImportSession) DeleteFromCache(ctx context.Context) error
  • func (is *ImportSession) FromJSON(d []byte) error
  • func (is *ImportSession) GetAddress() string
  • func (is *ImportSession) GetFromCache(ctx context.Context) error
  • func (is *ImportSession) SaveToCache(ctx context.Context) error
  • func (is *ImportSession) SaveToDB(c *fiber.Ctx) error
  • func (is *ImportSession) ToJSON() []byte

Functions

func Apply

func Apply(c *fiber.Ctx) error

func Import

func Import(c *fiber.Ctx, broker string) (*transaction.Transactions, error)

Types

type ImportSession

type ImportSession struct {
	UserID       uuid.UUID
	DateCreated  time.Time
	Transactions *transaction.Transactions
}

func NewImportSession

func NewImportSession(c *fiber.Ctx) (*ImportSession, error)

func (*ImportSession) DeleteFromCache

func (is *ImportSession) DeleteFromCache(ctx context.Context) error

func (*ImportSession) FromJSON

func (is *ImportSession) FromJSON(d []byte) error

func (*ImportSession) GetAddress

func (is *ImportSession) GetAddress() string

func (*ImportSession) GetFromCache

func (is *ImportSession) GetFromCache(ctx context.Context) error

func (*ImportSession) SaveToCache

func (is *ImportSession) SaveToCache(ctx context.Context) error

func (*ImportSession) SaveToDB

func (is *ImportSession) SaveToDB(c *fiber.Ctx) error

func (*ImportSession) ToJSON

func (is *ImportSession) ToJSON() []byte