mercury

Documentation

Index

• func RegisterMercuryAdapterServer(s *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
• type AdapterClient
  • func NewMercuryAdapterClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *AdapterClient
  • func (c *AdapterClient) NewMercuryV1Factory(ctx context.Context, provider types.MercuryProvider, ...) (types.MercuryPluginFactory, error)
  • func (c *AdapterClient) NewMercuryV2Factory(ctx context.Context, provider types.MercuryProvider, ...) (types.MercuryPluginFactory, error)
  • func (c *AdapterClient) NewMercuryV3Factory(ctx context.Context, provider types.MercuryProvider, ...) (types.MercuryPluginFactory, error)
• type AdapterServer
  • func NewMercuryAdapterServer(b *net.BrokerExt, impl types.PluginMercury) *AdapterServer
  • func (ms *AdapterServer) NewMercuryV1Factory(ctx context.Context, req *mercurypb.NewMercuryV1FactoryRequest) (*mercurypb.NewMercuryV1FactoryReply, error)
  • func (ms *AdapterServer) NewMercuryV2Factory(ctx context.Context, req *mercurypb.NewMercuryV2FactoryRequest) (*mercurypb.NewMercuryV2FactoryReply, error)
  • func (ms *AdapterServer) NewMercuryV3Factory(ctx context.Context, req *mercurypb.NewMercuryV3FactoryRequest) (*mercurypb.NewMercuryV3FactoryReply, error)
• type PluginFactoryClient
  • func NewPluginFactoryClient(b *net.BrokerExt, cc grpc.ClientConnInterface) *PluginFactoryClient
  • func (r *PluginFactoryClient) NewMercuryPlugin(config ocr3types.MercuryPluginConfig) (ocr3types.MercuryPlugin, ocr3types.MercuryPluginInfo, error)

Functions

func RegisterMercuryAdapterServer

func RegisterMercuryAdapterServer(s *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl types.PluginMercury) error

Types

type AdapterClient

type AdapterClient struct {
	*goplugin.PluginClient
	*goplugin.ServiceClient
	// contains filtered or unexported fields
}

func NewMercuryAdapterClient

func NewMercuryAdapterClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *AdapterClient

func (*AdapterClient) NewMercuryV1Factory

func (c *AdapterClient) NewMercuryV1Factory(ctx context.Context,
	provider types.MercuryProvider, dataSource mercuryv1.DataSource,
) (types.MercuryPluginFactory, error)

func (*AdapterClient) NewMercuryV2Factory

func (c *AdapterClient) NewMercuryV2Factory(ctx context.Context,
	provider types.MercuryProvider, dataSource mercuryv2.DataSource,
) (types.MercuryPluginFactory, error)

func (*AdapterClient) NewMercuryV3Factory

func (c *AdapterClient) NewMercuryV3Factory(ctx context.Context,
	provider types.MercuryProvider, dataSource mercuryv3.DataSource,
) (types.MercuryPluginFactory, error)

type AdapterServer

type AdapterServer struct {
	mercurypb.UnimplementedMercuryAdapterServer

	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewMercuryAdapterServer

func NewMercuryAdapterServer(b *net.BrokerExt, impl types.PluginMercury) *AdapterServer

func (*AdapterServer) NewMercuryV1Factory

func (ms *AdapterServer) NewMercuryV1Factory(ctx context.Context, req *mercurypb.NewMercuryV1FactoryRequest) (*mercurypb.NewMercuryV1FactoryReply, error)

func (*AdapterServer) NewMercuryV2Factory

func (ms *AdapterServer) NewMercuryV2Factory(ctx context.Context, req *mercurypb.NewMercuryV2FactoryRequest) (*mercurypb.NewMercuryV2FactoryReply, error)

func (*AdapterServer) NewMercuryV3Factory

func (ms *AdapterServer) NewMercuryV3Factory(ctx context.Context, req *mercurypb.NewMercuryV3FactoryRequest) (*mercurypb.NewMercuryV3FactoryReply, error)

type PluginFactoryClient

type PluginFactoryClient struct {
	*net.BrokerExt
	*goplugin.ServiceClient
	// contains filtered or unexported fields
}

func NewPluginFactoryClient

func NewPluginFactoryClient(b *net.BrokerExt, cc grpc.ClientConnInterface) *PluginFactoryClient

func (*PluginFactoryClient) NewMercuryPlugin

func (r *PluginFactoryClient) NewMercuryPlugin(config ocr3types.MercuryPluginConfig) (ocr3types.MercuryPlugin, ocr3types.MercuryPluginInfo, error)