subscriptions

Documentation

Index

• type EndOfBlock
• type Message
  • func NewAddressMessage(model *storage.Address) *Message
  • func NewBlockMessage(block *storage.Block) *Message
  • func NewDeclareMessage(model *storage.Declare) *Message
  • func NewDeployAccountMessage(model *storage.DeployAccount) *Message
  • func NewDeployMessage(model *storage.Deploy) *Message
  • func NewEndMessage(block *storage.Block) *Message
  • func NewEventMessage(model *storage.Event) *Message
  • func NewFeeMessage(model *storage.Fee) *Message
  • func NewInternalMessage(model *storage.Internal) *Message
  • func NewInvokeMessage(model *storage.Invoke) *Message
  • func NewL1HandlerMessage(model *storage.L1Handler) *Message
  • func NewStarknetMessage(model *storage.Message) *Message
  • func NewStorageDiffMessage(model *storage.StorageDiff) *Message
  • func NewTokenBalanceMessage(model *storage.TokenBalance) *Message
  • func NewTokenMessage(model *storage.Token) *Message
  • func NewTransferMessage(model *storage.Transfer) *Message
• type Subscription
  • func NewSubscription(ctx context.Context, db postgres.Storage, req *pb.SubscribeRequest) (*Subscription, error)
  • func (s *Subscription) Close() error
  • func (s *Subscription) Filter(msg *Message) bool
  • func (s *Subscription) Listen() <-chan *pb.Subscription
  • func (s *Subscription) Send(msg *pb.Subscription)

Types

type EndOfBlock

type EndOfBlock struct {
	Height uint64
}

EndOfBlock -

type Message

type Message struct {
	Block         *storage.Block
	Declare       *storage.Declare
	Deploy        *storage.Deploy
	DeployAccount *storage.DeployAccount
	Event         *storage.Event
	Fee           *storage.Fee
	Internal      *storage.Internal
	Invoke        *storage.Invoke
	L1Handler     *storage.L1Handler
	Message       *storage.Message
	StorageDiff   *storage.StorageDiff
	TokenBalance  *storage.TokenBalance
	Transfer      *storage.Transfer
	Token         *storage.Token
	Address       *storage.Address
	EndOfBlock    *EndOfBlock
}

Message -

func NewAddressMessage

func NewAddressMessage(model *storage.Address) *Message

NewAddressMessage -

func NewBlockMessage

func NewBlockMessage(block *storage.Block) *Message

NewBlockMessage -

func NewDeclareMessage

func NewDeclareMessage(model *storage.Declare) *Message

NewDeclareMessage -

func NewDeployAccountMessage

func NewDeployAccountMessage(model *storage.DeployAccount) *Message

NewDeployAccountMessage -

func NewDeployMessage

func NewDeployMessage(model *storage.Deploy) *Message

NewDeployMessage -

func NewEndMessage

func NewEndMessage(block *storage.Block) *Message

NewEndMessage -

func NewEventMessage

func NewEventMessage(model *storage.Event) *Message

NewEventMessage -

func NewFeeMessage

func NewFeeMessage(model *storage.Fee) *Message

NewFeeMessage -

func NewInternalMessage

func NewInternalMessage(model *storage.Internal) *Message

NewInternalMessage -

func NewInvokeMessage

func NewInvokeMessage(model *storage.Invoke) *Message

NewInvokeMessage -

func NewL1HandlerMessage

func NewL1HandlerMessage(model *storage.L1Handler) *Message

NewL1HandlerMessage -

func NewStarknetMessage

func NewStarknetMessage(model *storage.Message) *Message

NewStarknetMessage -

func NewStorageDiffMessage

func NewStorageDiffMessage(model *storage.StorageDiff) *Message

NewStorageDiffMessage -

func NewTokenBalanceMessage

func NewTokenBalanceMessage(model *storage.TokenBalance) *Message

NewTokenBalanceMessage -

func NewTokenMessage

func NewTokenMessage(model *storage.Token) *Message

NewTokenMessage -

func NewTransferMessage

func NewTransferMessage(model *storage.Transfer) *Message

NewTransferMessage -

type Subscription

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

Subscription -

func NewSubscription

func NewSubscription(ctx context.Context, db postgres.Storage, req *pb.SubscribeRequest) (*Subscription, error)

NewSubscription -

func (*Subscription) Close

func (s *Subscription) Close() error

Close -

func (*Subscription) Filter

func (s *Subscription) Filter(msg *Message) bool

Filter -

func (*Subscription) Listen

func (s *Subscription) Listen() <-chan *pb.Subscription

Listen -

func (*Subscription) Send

func (s *Subscription) Send(msg *pb.Subscription)

Send -