blockchain

Documentation

Index

• type ExtInMsgCopy
  • func (m *ExtInMsgCopy) IsEmulation() bool
• type MsgSender
  • func NewMsgSender(logger *zap.Logger, servers []config.LiteServer, ...) (*MsgSender, error)
  • func (ms *MsgSender) SendMessage(ctx context.Context, msgCopy ExtInMsgCopy) error
  • func (ms *MsgSender) SendMultipleMessages(ctx context.Context, copies []ExtInMsgCopy)
  • func (ms *MsgSender) SendingClientsNumber() int

Types

type ExtInMsgCopy

type ExtInMsgCopy struct {
	// MsgBoc is a base64 encoded message boc.
	MsgBoc string
	// Payload is a decoded message boc.
	Payload []byte
	// Details contains some optional details from a request context.
	Details any
	// Accounts is set when the message is emulated.
	Accounts map[tongo.AccountID]struct{}
}

ExtInMsgCopy represents an external message we receive on /v2/blockchain/message endpoint.

func (*ExtInMsgCopy) IsEmulation

func (m *ExtInMsgCopy) IsEmulation() bool

type MsgSender

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

MsgSender provides a method to send a message to the blockchain.

func NewMsgSender

func NewMsgSender(logger *zap.Logger, servers []config.LiteServer, receivers map[string]chan<- ExtInMsgCopy) (*MsgSender, error)

func (*MsgSender) SendMessage

func (ms *MsgSender) SendMessage(ctx context.Context, msgCopy ExtInMsgCopy) error

SendMessage sends the given a message to the blockchain.

func (*MsgSender) SendMultipleMessages

func (ms *MsgSender) SendMultipleMessages(ctx context.Context, copies []ExtInMsgCopy)

func (*MsgSender) SendingClientsNumber

func (ms *MsgSender) SendingClientsNumber() int