ws

Documentation

Index

• type BillImportWebsocket
  • func NewBillImportWebsocket(conn *websocket.Conn, account accountModel.Account) *BillImportWebsocket
  • func (b *BillImportWebsocket) Read() error
  • func (b *BillImportWebsocket) ReadFile() (name []byte, file io.Reader, err error)
  • func (b *BillImportWebsocket) RegisterMsgHandlerCreateRetry(handler func(transactionModel.Info) error)
  • func (b *BillImportWebsocket) RegisterMsgHandlerIgnoreTrans()
  • func (b *BillImportWebsocket) SendError() error
  • func (b *BillImportWebsocket) SendFinish() error
  • func (b *BillImportWebsocket) SendTransactionCreateFail(transInfo transactionModel.Info, failErr error) error
  • func (b *BillImportWebsocket) SendTransactionCreateSuccess(transaction transactionModel.Transaction) error
  • func (b *BillImportWebsocket) TryFinish() error
• type TotalData

Types

type BillImportWebsocket

type BillImportWebsocket struct {
	msg.Reader

	WaitRetryTrans *dataTool.RWMutexMap[string, transactionModel.Info]
	RetryingTrans  *dataTool.RWMutexMap[string, transactionModel.Info]
	// contains filtered or unexported fields
}

func NewBillImportWebsocket

func NewBillImportWebsocket(conn *websocket.Conn, account accountModel.Account) *BillImportWebsocket

func (*BillImportWebsocket) Read

func (b *BillImportWebsocket) Read() error

func (*BillImportWebsocket) ReadFile

func (b *BillImportWebsocket) ReadFile() (name []byte, file io.Reader, err error)

func (*BillImportWebsocket) RegisterMsgHandlerCreateRetry

func (b *BillImportWebsocket) RegisterMsgHandlerCreateRetry(handler func(transactionModel.Info) error)

func (*BillImportWebsocket) RegisterMsgHandlerIgnoreTrans

func (b *BillImportWebsocket) RegisterMsgHandlerIgnoreTrans()

func (*BillImportWebsocket) SendError

func (b *BillImportWebsocket) SendError() error

func (*BillImportWebsocket) SendFinish

func (b *BillImportWebsocket) SendFinish() error

func (*BillImportWebsocket) SendTransactionCreateFail

func (b *BillImportWebsocket) SendTransactionCreateFail(transInfo transactionModel.Info, failErr error) error

func (*BillImportWebsocket) SendTransactionCreateSuccess

func (b *BillImportWebsocket) SendTransactionCreateSuccess(transaction transactionModel.Transaction) error

func (*BillImportWebsocket) TryFinish

func (b *BillImportWebsocket) TryFinish() error

type TotalData

type TotalData struct {
	ExpenseAmount, IncomeAmount            atomic.Int64
	ExpenseCount, IncomeCount, IgnoreCount atomic.Int32
}