interactive

Documentation

Index

• Constants
• type Backend
• type BackendFactory
• type Certification
• type CertificationClient
  • func NewCertificationClient(ctx context.Context, channel string, namespace string, qe QueryEngine, ...) *CertificationClient
  • func (cc *CertificationClient) IsCertified(id *token.ID) bool
  • func (cc *CertificationClient) OnReceive(event events.Event)
  • func (cc *CertificationClient) RequestCertification(ids ...*token.ID) error
  • func (cc *CertificationClient) Scan() error
  • func (cc *CertificationClient) Start()
• type CertificationRequest
  • func (cr *CertificationRequest) String() string
• type CertificationRequestView
  • func NewCertificationRequestView(channel, ns string, certifier view.Identity, ids ...*token.ID) *CertificationRequestView
  • func (i *CertificationRequestView) Call(context view.Context) (interface{}, error)
• type CertificationService
  • func NewCertificationService(responderRegistry ResponderRegistry, mp metrics.Provider, backend Backend) *CertificationService
  • func (c *CertificationService) Call(context view.Context) (interface{}, error)
  • func (c *CertificationService) SetWallet(tms *token2.ManagementService, wallet string)
  • func (c *CertificationService) Start() (err error)
• type CertificationStorage
• type ChaincodeBackend
  • func (c *ChaincodeBackend) Load(context view.Context, cr *CertificationRequest) ([][]byte, error)
• type Driver
  • func NewDriver(backendFactory BackendFactory, resolver Resolver, subscriber Subscriber, ...) *Driver
  • func (d *Driver) NewCertificationClient(tms *token.ManagementService) (driver.CertificationClient, error)
  • func (d *Driver) NewCertificationService(tms *token.ManagementService, wallet string) (driver.CertificationService, error)
• type Metrics
  • func NewMetrics(p metrics.Provider) *Metrics
• type Op
• type QueryEngine
• type Resolver
• type ResponderRegistry
• type Subscriber
• type ViewManager

Constants

const (
	ConfigurationKey = "certification.interactive"
)

Types

type Backend

type Backend interface {
	Load(context view.Context, cr *CertificationRequest) ([][]byte, error)
}

type BackendFactory

type BackendFactory func(tms *token.ManagementService, wallet string) (Backend, error)

type Certification

type Certification struct {
	IDs []string `yaml:"ids,omitempty"`
}

type CertificationClient

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

CertificationClient scans the vault for tokens not yet certified and asks the certification.

func NewCertificationClient

func NewCertificationClient(
	ctx context.Context,
	channel string,
	namespace string,
	qe QueryEngine,
	cm CertificationStorage,
	fm ViewManager,
	certifiers []view2.Identity,
	notifier events.Subscriber,
	maxAttempts int,
	waitTime time.Duration,
) *CertificationClient

func (*CertificationClient) IsCertified

func (cc *CertificationClient) IsCertified(id *token.ID) bool

func (*CertificationClient) OnReceive

func (cc *CertificationClient) OnReceive(event events.Event)

func (*CertificationClient) RequestCertification

func (cc *CertificationClient) RequestCertification(ids ...*token.ID) error

func (*CertificationClient) Scan

func (cc *CertificationClient) Scan() error

func (*CertificationClient) Start

func (cc *CertificationClient) Start()

type CertificationRequest

type CertificationRequest struct {
	Network, Channel, Namespace string
	IDs                         []*token.ID
	Request                     []byte
}

func (*CertificationRequest) String

func (cr *CertificationRequest) String() string

type CertificationRequestView

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

func NewCertificationRequestView

func NewCertificationRequestView(channel, ns string, certifier view.Identity, ids ...*token.ID) *CertificationRequestView

func (*CertificationRequestView) Call

func (i *CertificationRequestView) Call(context view.Context) (interface{}, error)

type CertificationService

type CertificationService struct {
	ResponderRegistry ResponderRegistry
	// contains filtered or unexported fields
}

func NewCertificationService

func NewCertificationService(responderRegistry ResponderRegistry, mp metrics.Provider, backend Backend) *CertificationService

func (*CertificationService) Call

func (c *CertificationService) Call(context view.Context) (interface{}, error)

func (*CertificationService) SetWallet

func (c *CertificationService) SetWallet(tms *token2.ManagementService, wallet string)

func (*CertificationService) Start

func (c *CertificationService) Start() (err error)

type CertificationStorage

type CertificationStorage interface {
	Exists(id *token.ID) bool
	Store(certifications map[*token.ID][]byte) error
}

type ChaincodeBackend

type ChaincodeBackend struct{}

func (*ChaincodeBackend) Load

func (c *ChaincodeBackend) Load(context view.Context, cr *CertificationRequest) ([][]byte, error)

type Driver

type Driver struct {
	BackendFactory    BackendFactory
	Resolver          Resolver
	Subscriber        Subscriber
	ViewManager       ViewManager
	ResponderRegistry ResponderRegistry
	MetricsProvider   metrics.Provider

	Sync                 sync.Mutex
	CertificationClients map[string]*CertificationClient
	CertificationService *CertificationService
}

func NewDriver

func NewDriver(backendFactory BackendFactory, resolver Resolver, subscriber Subscriber, viewManager ViewManager, responderRegistry ResponderRegistry, metricsProvider metrics.Provider) *Driver

func (*Driver) NewCertificationClient

func (d *Driver) NewCertificationClient(tms *token.ManagementService) (driver.CertificationClient, error)

func (*Driver) NewCertificationService

func (d *Driver) NewCertificationService(tms *token.ManagementService, wallet string) (driver.CertificationService, error)

type Metrics

type Metrics struct {
	CertifiedTokens metrics.Counter
}

func NewMetrics

func NewMetrics(p metrics.Provider) *Metrics

type Op

type Op uint8

const (
	Add Op = iota
)

type QueryEngine

type QueryEngine interface {
	UnspentTokensIterator() (*token2.UnspentTokensIterator, error)
}

type Resolver

type Resolver interface {
	ResolveIdentities(endpoints ...string) ([]view.Identity, error)
}

type ResponderRegistry

type ResponderRegistry interface {
	RegisterResponder(responder view.View, initiatedBy interface{}) error
}

type Subscriber

type Subscriber = events.Subscriber

type ViewManager

type ViewManager interface {
	InitiateView(view view.View) (interface{}, error)
}