store

Documentation

Index

• Constants
• func AddrFeedKey(addr address.Address) string
• type ActorTracker
  • func New(rdb *redis.Client) *ActorTracker
  • func (at *ActorTracker) Clear()
  • func (at *ActorTracker) Flush(ctx context.Context) error
  • func (at *ActorTracker) Len() int
  • func (at *ActorTracker) Load(ctx context.Context) (int, error)
  • func (at *ActorTracker) RecordMessage(msg MessageRecord) bool
• type MessageRecord

Constants

const (
	TrackingAddrKey       = "tracking_addrs"
	TrackingAddrUpdateKey = "tracking_addrs_update"
	LastHeightKey         = "last_height"
)

Functions

func AddrFeedKey

func AddrFeedKey(addr address.Address) string

Types

type ActorTracker

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

func New

func New(rdb *redis.Client) *ActorTracker

func (*ActorTracker) Clear

func (at *ActorTracker) Clear()

func (*ActorTracker) Flush

func (at *ActorTracker) Flush(ctx context.Context) error

func (*ActorTracker) Len

func (at *ActorTracker) Len() int

func (*ActorTracker) Load

func (at *ActorTracker) Load(ctx context.Context) (int, error)

func (*ActorTracker) RecordMessage

func (at *ActorTracker) RecordMessage(msg MessageRecord) bool

type MessageRecord

type MessageRecord struct {
	Message    *types.Message
	MessageCid cid.Cid
	Block      *types.BlockHeader
	TipSetKey  types.TipSetKey
}