dynamicselection

Documentation

Index

• type CCPolicyProvider
• type ChannelUser
• type Opt
  • func WithCacheTimeout(timeout time.Duration) Opt
  • func WithLoadBalancePolicy(lbp pgresolver.LoadBalancePolicy) Opt
• type SelectionProvider
  • func New(config core.Config, users []ChannelUser, opts ...Opt) (*SelectionProvider, error)
  • func (p *SelectionProvider) Close()
  • func (p *SelectionProvider) CreateSelectionService(channelID string) (fab.SelectionService, error)
  • func (p *SelectionProvider) Initialize(providers contextAPI.Providers) error

Types

type CCPolicyProvider

type CCPolicyProvider interface {
	GetChaincodePolicy(chaincodeID string) (*common.SignaturePolicyEnvelope, error)
}

CCPolicyProvider retrieves policy for the given chaincode ID

type ChannelUser

type ChannelUser struct {
	ChannelID string
	Username  string
	OrgName   string
}

ChannelUser contains user(identity) info to be used for specific channel

type Opt

type Opt func(*SelectionProvider)

Opt applies a selection provider option

func WithCacheTimeout

func WithCacheTimeout(timeout time.Duration) Opt

WithCacheTimeout sets the expiration timeout of the cache

func WithLoadBalancePolicy

func WithLoadBalancePolicy(lbp pgresolver.LoadBalancePolicy) Opt

WithLoadBalancePolicy sets the load-balance policy

type SelectionProvider

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

SelectionProvider implements selection provider TODO: refactor users into client contexts

func New

func New(config core.Config, users []ChannelUser, opts ...Opt) (*SelectionProvider, error)

New returns dynamic selection provider

func (*SelectionProvider) Close

func (p *SelectionProvider) Close()

Close the selection services created by this provider

func (*SelectionProvider) CreateSelectionService

func (p *SelectionProvider) CreateSelectionService(channelID string) (fab.SelectionService, error)

CreateSelectionService creates a selection service

func (*SelectionProvider) Initialize

func (p *SelectionProvider) Initialize(providers contextAPI.Providers) error

Initialize allow for initializing providers