manager

Documentation

Index

• type FeedContent
• type FeedObject
• type Manager
  • func New(logger logging.Logger, config *fconfig.Config, db *sql.DB) (*Manager, error)
  • func (m *Manager) Config() *fconfig.Config
  • func (m *Manager) GetFeed(_ context.Context, subnetID, chainID string, limit int) ([]*FeedObject, error)
  • func (m *Manager) GetFeedInfo(_ context.Context) (codec.Address, uint64, error)
  • func (m *Manager) Run(ctx context.Context) error
  • func (m *Manager) UpdateNuklaiRPC(ctx context.Context, newNuklaiRPCUrl string) error

Types

type FeedContent

type FeedContent struct {
	Message string `json:"message"`
	URL     string `json:"url"`
}

type FeedObject

type FeedObject struct {
	SubnetID  string `json:"subnetID"`
	ChainID   string `json:"chainID"`
	Address   string `json:"address"`
	TxID      ids.ID `json:"txID"`
	Timestamp int64  `json:"timestamp"`
	Fee       uint64 `json:"fee"`

	Content *FeedContent `json:"content"`
}

type Manager

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

func New

func New(logger logging.Logger, config *fconfig.Config, db *sql.DB) (*Manager, error)

func (*Manager) Config

func (m *Manager) Config() *fconfig.Config

Config returns the configuration of the manager

func (*Manager) GetFeed

func (m *Manager) GetFeed(_ context.Context, subnetID, chainID string, limit int) ([]*FeedObject, error)

func (*Manager) GetFeedInfo

func (m *Manager) GetFeedInfo(_ context.Context) (codec.Address, uint64, error)

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

func (*Manager) UpdateNuklaiRPC

func (m *Manager) UpdateNuklaiRPC(ctx context.Context, newNuklaiRPCUrl string) error