watchlist

Documentation

Index

• type AssetDetails
  • func (s AssetDetails) Validate() error
• type Details
• type Opts
• type Service
  • func New(opts Opts) *Service
  • func (s *Service) GetToAdd() <-chan Details
  • func (s *Service) GetToRemove() <-chan string
  • func (s *Service) Run(ctx context.Context)

Types

type AssetDetails

type AssetDetails struct {
	Stellar struct {
		Withdraw  bool   `json:"withdraw"`
		AssetType string `json:"asset_type"`
		Code      string `json:"asset_code"`
		Issuer    string `json:"issuer"`
	} `json:"stellar"`
}

func (AssetDetails) Validate

func (s AssetDetails) Validate() error

type Details

type Details struct {
	regources.Asset
	AssetDetails
}

type Opts

type Opts struct {
	Streamer   getters.AssetHandler
	Log        *logan.Entry
	AssetOwner string
}

type Service

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

func New

func New(opts Opts) *Service

func (*Service) GetToAdd

func (s *Service) GetToAdd() <-chan Details

func (*Service) GetToRemove

func (s *Service) GetToRemove() <-chan string

func (*Service) Run

func (s *Service) Run(ctx context.Context)