gateway

Documentation

Index

• func Scheme(ctx context.Context) meta.Scheme
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)
  • func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)
  • func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type Plugin

type Plugin struct {
	// capabilityv1.UnsafeBackendServer
	system.UnimplementedSystemPluginClient
	collector.CollectorServer
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin(ctx context.Context) *Plugin

func (*Plugin) StreamServers

func (p *Plugin) StreamServers() []streamext.Server

func (*Plugin) UseKeyValueStore

func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)

func (*Plugin) UseManagementAPI

func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)

func (*Plugin) UseStreamClient

func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)