interactive

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

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

type Certification struct {
	// IDs lists the endpoint identifiers of the remote certifier nodes.
	IDs []string `yaml:"ids,omitempty"`

	// MaxAttempts is the maximum number of times a certification request is
	// retried before the batch is discarded. Zero uses DefaultMaxAttempts.
	MaxAttempts int `yaml:"maxAttempts,omitempty"`

	// WaitTime is the backoff duration between retry attempts.
	// Zero uses DefaultWaitTime.
	WaitTime time.Duration `yaml:"waitTime,omitempty"`

	// BatchSize is the maximum number of tokens assembled into a single
	// certification request. Zero uses DefaultBatchSize.
	BatchSize int `yaml:"batchSize,omitempty"`

	// BufferSize is the capacity of the incoming token channel. Tokens are
	// dropped (and counted) when the buffer is full. Zero uses DefaultBufferSize.
	BufferSize int `yaml:"bufferSize,omitempty"`

	// FlushInterval is the maximum time a partial batch waits before being
	// dispatched to the worker pool. Zero uses DefaultFlushInterval.
	FlushInterval time.Duration `yaml:"flushInterval,omitempty"`

	// Workers is the number of concurrent goroutines that process certification
	// batches. Zero uses DefaultWorkers.
	Workers int `yaml:"workers,omitempty"`

	// ResponseTimeout is the maximum time the client waits for the certifier to
	// respond before treating the request as failed. Zero uses DefaultResponseTimeout.
	ResponseTimeout time.Duration `yaml:"responseTimeout,omitempty"`
}

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

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

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

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

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

type ChaincodeBackend struct{}

type ClientMetrics struct {
	// RequestDuration is a histogram of end-to-end certification batch durations.
	RequestDuration metrics.Histogram
	// Errors counts failed certification request attempts.
	Errors metrics.Counter
	// PendingTokens is a gauge tracking how many tokens are waiting in the input buffer.
	PendingTokens metrics.Gauge
	// DroppedTokens counts tokens dropped because the input buffer was full.
	DroppedTokens metrics.Counter
}

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
}

type Metrics struct {
	CertifiedTokens metrics.Counter
}

type Op uint8

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

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

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

type Subscriber = events.Subscriber

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