plugin

package

Go to main page

Versions in this module

v0

v0.8.0

Oct 15, 2019

v0.7.0

Sep 18, 2019

Changes in this version

type ModuleProxy

+ func (ModuleProxy) ResetCRDs(ctx context.Context) error

+ func (m *ModuleProxy) ClientRequestHandlers() []octant.ClientRequestHandler

v0.6.0

Aug 21, 2019

Changes in this version

+ var Name = "plugin"

+ type TabResponse struct

+ Tab *component.Tab

v0.5.1

Aug 6, 2019

v0.5.0

Aug 5, 2019

v0.4.1

Jul 29, 2019

v0.4.0

Jul 19, 2019

Changes in this version

+ var DefaultConfig = &defaultConfig

+ var Handshake = plugin.HandshakeConfig

+ var PluginName = "plugin"

+ func AvailablePlugins(config Config) ([]string, error)

+ func Serve(service Service)

+ type ActionRegistrar interface

+ Register func(actionPath string, actionFunc action.DispatcherFunc) error

+ type Broker interface

+ AcceptAndServe func(id uint32, s func([]grpc.ServerOption) *grpc.Server)

+ NextId func() uint32

+ type Capabilities struct

+ ActionNames []string

+ IsModule bool

+ SupportsObjectStatus []schema.GroupVersionKind

+ SupportsPrinterConfig []schema.GroupVersionKind

+ SupportsPrinterItems []schema.GroupVersionKind

+ SupportsPrinterStatus []schema.GroupVersionKind

+ SupportsTab []schema.GroupVersionKind

+ func (c Capabilities) HasPrinterSupport(gvk schema.GroupVersionKind) bool

+ func (c Capabilities) HasTabSupport(gvk schema.GroupVersionKind) bool

+ type Client interface

+ Client func() (plugin.ClientProtocol, error)

+ Kill func()

+ type ClientFactory interface

+ Init func(ctx context.Context, cmd string) Client

+ type Config interface

+ Fs func() afero.Fs

+ Home func() string

+ PluginDirs func() ([]string, error)

+ type DefaultClientFactory struct

+ func NewDefaultClientFactory() *DefaultClientFactory

+ func (f *DefaultClientFactory) Init(ctx context.Context, cmd string) Client

+ type DefaultRunner struct

+ RunFunc func(name string, gvk schema.GroupVersionKind, object runtime.Object) error

+ func ObjectStatusRunner(store ManagerStore, ch chan<- ObjectStatusResponse) DefaultRunner

+ func PrintRunner(store ManagerStore, ch chan<- PrintResponse) DefaultRunner

+ func TabRunner(store ManagerStore, ch chan<- component.Tab) DefaultRunner

+ func (pr *DefaultRunner) Run(object runtime.Object, clientNames []string) error

+ type DefaultStore struct

+ func NewDefaultStore() *DefaultStore

+ func (s *DefaultStore) ClientNames() []string

+ func (s *DefaultStore) Clients() map[string]Client

+ func (s *DefaultStore) GetCommand(name string) (string, error)

+ func (s *DefaultStore) GetMetadata(name string) (*Metadata, error)

+ func (s *DefaultStore) GetService(name string) (Service, error)

+ func (s *DefaultStore) Store(name string, client Client, metadata *Metadata, cmd string) error

+ type GRPCClient struct

+ func NewGRPCClient(broker Broker, client dashboard.PluginClient) *GRPCClient

+ func (c *GRPCClient) Content(contentPath string) (component.ContentResponse, error)

+ func (c *GRPCClient) HandleAction(payload action.Payload) error

+ func (c *GRPCClient) Navigation() (navigation.Navigation, error)

+ func (c *GRPCClient) ObjectStatus(object runtime.Object) (ObjectStatusResponse, error)

+ func (c *GRPCClient) Print(object runtime.Object) (PrintResponse, error)

+ func (c *GRPCClient) PrintTab(object runtime.Object) (*component.Tab, error)

+ func (c *GRPCClient) Register(dashboardAPIAddress string) (Metadata, error)

+ type GRPCServer struct

+ Impl Service

+ func (s *GRPCServer) Content(ctx context.Context, req *dashboard.ContentRequest) (*dashboard.ContentResponse, error)

+ func (s *GRPCServer) HandleAction(ctx context.Context, handleActionRequest *dashboard.HandleActionRequest) (*dashboard.HandleActionResponse, error)

+ func (s *GRPCServer) Navigation(context.Context, *dashboard.NavigationRequest) (*dashboard.NavigationResponse, error)

+ func (s *GRPCServer) ObjectStatus(ctx context.Context, objectRequest *dashboard.ObjectRequest) (*dashboard.ObjectStatusResponse, error)

+ func (s *GRPCServer) Print(ctx context.Context, objectRequest *dashboard.ObjectRequest) (*dashboard.PrintResponse, error)

+ func (s *GRPCServer) PrintTab(ctx context.Context, objectRequest *dashboard.ObjectRequest) (*dashboard.PrintTabResponse, error)

+ func (s *GRPCServer) Register(ctx context.Context, registerRequest *dashboard.RegisterRequest) (*dashboard.RegisterResponse, error)

+ func (s *GRPCServer) WatchAdd(context.Context, *dashboard.WatchRequest) (*dashboard.Empty, error)

+ func (s *GRPCServer) WatchDelete(context.Context, *dashboard.WatchRequest) (*dashboard.Empty, error)

+ func (s *GRPCServer) WatchUpdate(context.Context, *dashboard.WatchRequest) (*dashboard.Empty, error)

+ type Manager struct

+ API api.API

+ ActionRegistrar ActionRegistrar

+ ClientFactory ClientFactory

+ ModuleRegistrar ModuleRegistrar

+ PortForwarder portforward.PortForwarder

+ Runners Runners

+ func NewManager(apiService api.API, moduleRegistrar ModuleRegistrar, ...) *Manager

+ func (m *Manager) Load(cmd string) error

+ func (m *Manager) ObjectStatus(object runtime.Object) (*ObjectStatusResponse, error)

+ func (m *Manager) Print(object runtime.Object) (*PrintResponse, error)

+ func (m *Manager) SetStore(store ManagerStore)

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) Stop(ctx context.Context)

+ func (m *Manager) Store() ManagerStore

+ func (m *Manager) Tabs(object runtime.Object) ([]component.Tab, error)

+ type ManagerInterface interface

+ ObjectStatus func(object runtime.Object) (*ObjectStatusResponse, error)

+ Print func(object runtime.Object) (*PrintResponse, error)

+ Store func() ManagerStore

+ Tabs func(object runtime.Object) ([]component.Tab, error)

+ type ManagerOption func(*Manager)

+ type ManagerStore interface

+ ClientNames func() []string

+ Clients func() map[string]Client

+ GetCommand func(name string) (string, error)

+ GetMetadata func(name string) (*Metadata, error)

+ GetService func(name string) (Service, error)

+ Store func(name string, client Client, metadata *Metadata, cmd string) error

+ type Metadata struct

+ Capabilities Capabilities

+ Description string

+ Name string

+ type ModuleProxy struct

+ Metadata *Metadata

+ PluginName string

+ Service ModuleService

+ func NewModuleProxy(pluginName string, metadata *Metadata, service ModuleService) (*ModuleProxy, error)

+ func (ModuleProxy) AddCRD(ctx context.Context, crd *unstructured.Unstructured) error

+ func (ModuleProxy) Generators() []octant.Generator

+ func (ModuleProxy) GroupVersionKindPath(namespace, apiVersion, kind, name string) (string, error)

+ func (ModuleProxy) Handlers(ctx context.Context) map[string]http.Handler

+ func (ModuleProxy) RemoveCRD(ctx context.Context, crd *unstructured.Unstructured) error

+ func (ModuleProxy) SetContext(ctx context.Context, contextName string) error

+ func (ModuleProxy) SetNamespace(namespace string) error

+ func (ModuleProxy) Start() error

+ func (ModuleProxy) Stop()

+ func (ModuleProxy) SupportedGroupVersionKind() []schema.GroupVersionKind

+ func (m *ModuleProxy) Content(ctx context.Context, contentPath, prefix, namespace string, ...) (component.ContentResponse, error)

+ func (m *ModuleProxy) ContentPath() string

+ func (m *ModuleProxy) Name() string

+ func (m *ModuleProxy) Navigation(ctx context.Context, namespace, root string) ([]navigation.Navigation, error)

+ type ModuleRegistrar interface

+ Register func(mod module.Module) error

+ type ModuleService interface

+ Content func(contentPath string) (component.ContentResponse, error)

+ Navigation func() (navigation.Navigation, error)

+ type ObjectStatusResponse struct

+ ObjectStatus component.PodSummary

+ type PrintResponse struct

+ Config []component.SummarySection

+ Items []component.FlexLayoutItem

+ Status []component.SummarySection

+ type Runners interface

+ ObjectStatus func(ManagerStore) (DefaultRunner, chan ObjectStatusResponse)

+ Print func(ManagerStore) (DefaultRunner, chan PrintResponse)

+ Tab func(ManagerStore) (DefaultRunner, chan component.Tab)

+ type Service interface

+ HandleAction func(payload action.Payload) error

+ ObjectStatus func(object runtime.Object) (ObjectStatusResponse, error)

+ Print func(object runtime.Object) (PrintResponse, error)

+ PrintTab func(object runtime.Object) (*component.Tab, error)

+ Register func(dashboardAPIAddress string) (Metadata, error)

+ type ServicePlugin struct

+ Impl Service

+ func (p *ServicePlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *ServicePlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

v0.3.0

Jun 17, 2019

v0.2.1

Apr 19, 2019

v0.2.0

Apr 15, 2019

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL