finality

Documentation

Index

• func NewListenerManagerConfig(configService driver.ConfigService) *serviceListenerManagerConfig
• type FinalityListener
  • func (t *FinalityListener) OnStatus(ctx context.Context, txID string, status int, message string)
• type ListenerManager
• type ListenerManagerConfig
• type ListenerManagerProvider
  • func NewListenerManagerProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, ...) ListenerManagerProvider
• type ManagerType

Functions

func NewListenerManagerConfig

func NewListenerManagerConfig(configService driver.ConfigService) *serviceListenerManagerConfig

Types

type FinalityListener

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

func (*FinalityListener) OnStatus

func (t *FinalityListener) OnStatus(ctx context.Context, txID string, status int, message string)

type ListenerManager

type ListenerManager = driver.FinalityListenerManager

type ListenerManagerConfig

type ListenerManagerConfig interface {
	Type() ManagerType
	CommitterMaxRetries() int
	CommitterRetryWaitDuration() time.Duration
	DeliveryMapperParallelism() int
	DeliveryBlockProcessParallelism() int
	DeliveryListenerTimeout() time.Duration
	DeliveryLRUSize() int
	DeliveryLRUBuffer() int
}

type ListenerManagerProvider

type ListenerManagerProvider interface {
	NewManager(network, channel string) (ListenerManager, error)
}

func NewListenerManagerProvider

func NewListenerManagerProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, keyTranslator translator.KeyTranslator, config ListenerManagerConfig) ListenerManagerProvider

type ManagerType

type ManagerType string

const (
	Committer ManagerType = "committer"
	Delivery  ManagerType = "delivery"
)