factory

Documentation

Index

• func CreateSovereignNotifier(args ArgsCreateSovereignNotifier) (process.SovereignNotifier, error)
• func CreateWsClientReceiverNotifier(args ArgsWsClientReceiverNotifier) (process.WSClient, error)
• func CreateWsSovereignNotifier(cfg config.Config) (process.WSClient, error)
• type ArgsCreateSovereignNotifier
• type ArgsWsClientReceiverNotifier

Functions

func CreateSovereignNotifier

func CreateSovereignNotifier(args ArgsCreateSovereignNotifier) (process.SovereignNotifier, error)

CreateSovereignNotifier creates a sovereign notifier which will notify subscribed handlers about incoming headers

func CreateWsClientReceiverNotifier

func CreateWsClientReceiverNotifier(args ArgsWsClientReceiverNotifier) (process.WSClient, error)

CreateWsClientReceiverNotifier creates a ws client receiver for incoming outport blocks

func CreateWsSovereignNotifier

func CreateWsSovereignNotifier(cfg config.Config) (process.WSClient, error)

CreateWsSovereignNotifier will create a ws sovereign shard notifier

Types

type ArgsCreateSovereignNotifier

type ArgsCreateSovereignNotifier struct {
	MarshallerType   string
	HasherType       string
	SubscribedEvents []config.SubscribedEvent
}

ArgsCreateSovereignNotifier is a struct placeholder for sovereign notifier args

type ArgsWsClientReceiverNotifier

type ArgsWsClientReceiverNotifier struct {
	WebSocketConfig   config.WebSocketConfig
	SovereignNotifier process.SovereignNotifier
}

ArgsWsClientReceiverNotifier is a struct placeholder for ws client receiver args