- SupportedSbis = []*SbiEngineConfig{
- &SbiEngineConfig{
- SbiEngine{
- Name: "nngpub",
- Version: "v1",
- Protocol: "nngpubsub",
- },
- openSocket(openNngPub),
- closeSocket(closeNngPub),
- createEndpointSocket(createNngPubEndpointSocket),
- destroyEndpointSocket(createNngPubEndpointSocket),
- distributeAll(publishAll),
- true,
- },
- &SbiEngineConfig{
- SbiEngine{
- Name: "nngpush",
- Version: "v1",
- Protocol: "nngpipeline",
- },
- openSocket(openNngPush),
- closeSocket(closeNngPush),
- createEndpointSocket(createNngPushEndpointSocket),
- destroyEndpointSocket(destroyNngPushEndpointSocket),
- distributeAll(pushAll),
- true,
+ SupportedSbis = []*EngineConfig{
+ {
+ Name: "nngpush",
+ Version: "v1",
+ Protocol: "nngpipeline",
+ Instance: NewNngPush(),
+ IsAvailable: true,