directory

Documentation

Index

• Variables
• type PaginatedMembersIterator
  • func ListMembers(client gds.Directory) *PaginatedMembersIterator
  • func (i *PaginatedMembersIterator) Err() error
  • func (i *PaginatedMembersIterator) Members() []*members.VASPMember
  • func (i *PaginatedMembersIterator) Next() bool
• type Sync
  • func New(conf config.DirectorySyncConfig, network network.Network, ...) (s *Sync, err error)
  • func (s *Sync) Counterparty(vaspID string) (vasp *models.Counterparty, err error)
  • func (s *Sync) MakeSourceMap() (local map[string]ulid.ULID, err error)
  • func (s *Sync) Run() error
  • func (s *Sync) Stop() error
  • func (s *Sync) Sync() (err error)

Variables

var (
	ErrSyncAlreadyRunning = errors.New("directory sync is already running")
	ErrSyncNotRunning     = errors.New("directory sync is not running")
)

Types

type PaginatedMembersIterator

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

func ListMembers

func ListMembers(client gds.Directory) *PaginatedMembersIterator

func (*PaginatedMembersIterator) Err

func (i *PaginatedMembersIterator) Err() error

func (*PaginatedMembersIterator) Members

func (i *PaginatedMembersIterator) Members() []*members.VASPMember

func (*PaginatedMembersIterator) Next

func (i *PaginatedMembersIterator) Next() bool

type Sync

type Sync struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Syncs the VASPs stored in the Global TRISA Directory (GDS) to local storage for easier counterparty lookup and analysis. This is a background routine that runs at a specified interval and ensures that only counterparties managed by the sync tool are updated in the local database.

func New

func New(conf config.DirectorySyncConfig, network network.Network, store store.CounterpartyStore, echan chan<- error) (s *Sync, err error)

Creates a new directory synchronization service but does not run it.

func (*Sync) Counterparty

func (s *Sync) Counterparty(vaspID string) (vasp *models.Counterparty, err error)

func (*Sync) MakeSourceMap

func (s *Sync) MakeSourceMap() (local map[string]ulid.ULID, err error)

func (*Sync) Run

func (s *Sync) Run() error

Run the directory synchronization service.

func (*Sync) Stop

func (s *Sync) Stop() error

Stop the directory synchronization service, blocking until the service is shutdown.

func (*Sync) Sync

func (s *Sync) Sync() (err error)