status

Documentation

Index

• Constants
• type Repository
  • func NewRepositoryForStatus(dbClient *gorm.DB, statusType string) *Repository
  • func (s Repository) CreateTimestamp(entityID string, timestamp int64) error
  • func (s Repository) GetLastFetchedTimestamp(entityID string) (int64, error)
  • func (s Repository) UpdateLastFetchedTimestamp(entityID string, timestamp int64) error

Constants

const (
	Transfer = "TRANSFER"
	Message  = "TOPIC_MESSAGE"
)

Hedera Watcher SDK message types

Types

type Repository

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

func NewRepositoryForStatus

func NewRepositoryForStatus(dbClient *gorm.DB, statusType string) *Repository

func (Repository) CreateTimestamp

func (s Repository) CreateTimestamp(entityID string, timestamp int64) error

func (Repository) GetLastFetchedTimestamp

func (s Repository) GetLastFetchedTimestamp(entityID string) (int64, error)

func (Repository) UpdateLastFetchedTimestamp

func (s Repository) UpdateLastFetchedTimestamp(entityID string, timestamp int64) error