endpoints

package
v2.4.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 11, 2018 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppnameEndpoint 

type AppnameEndpoint struct {
	// contains filtered or unexported fields
}

func NewAppnameEndpoint 

func NewAppnameEndpoint() *AppnameEndpoint

func (*AppnameEndpoint) Get 

func (ed *AppnameEndpoint) Get(ctx context.Context, in *pb.AppnameRequest) (*pb.AppnameReply, error)

type AppsEndpoint 

type AppsEndpoint struct {
	// contains filtered or unexported fields
}

func NewAppsEndpoint 

func NewAppsEndpoint(podgroup watcher.Watcher) *AppsEndpoint

func (*AppsEndpoint) Get 

func (ed *AppsEndpoint) Get(ctx context.Context, in *pb.AppsRequest) (*pb.AppsReply, error)

CODE GENERATION 1 START

func (*AppsEndpoint) Watch 

func (ed *AppsEndpoint) Watch(in *pb.AppsRequest, stream pb.Apps_WatchServer) error

type BackupctlEndpoint 

type BackupctlEndpoint struct {
	// contains filtered or unexported fields
}

func NewBackupctlEndpoint 

func NewBackupctlEndpoint(podgroup watcher.Watcher) *BackupctlEndpoint

func (*BackupctlEndpoint) Get 

func (ed *BackupctlEndpoint) Get(ctx context.Context, in *pb.BackupctlRequest) (*pb.BackupctlReply, error)

CODE GENERATION 1 START

func (*BackupctlEndpoint) Watch 

func (ed *BackupctlEndpoint) Watch(in *pb.BackupctlRequest, stream pb.Backupctl_WatchServer) error

type ConfigEndpoint 

type ConfigEndpoint struct {
	// contains filtered or unexported fields
}

func NewConfigEndpoint 

func NewConfigEndpoint(configWatcher watcher.Watcher) *ConfigEndpoint

func (*ConfigEndpoint) Get 

func (ed *ConfigEndpoint) Get(ctx context.Context, in *pb.ConfigRequest) (*pb.ConfigReply, error)

CODE GENERATION 1 START

func (*ConfigEndpoint) Watch 

func (ed *ConfigEndpoint) Watch(in *pb.ConfigRequest, stream pb.Config_WatchServer) error

type ContainersEndpoint 

type ContainersEndpoint struct {
	// contains filtered or unexported fields
}

func NewContainersEndpoint 

func NewContainersEndpoint(containerWatcher watcher.Watcher) *ContainersEndpoint

func (*ContainersEndpoint) Get 

func (ed *ContainersEndpoint) Get(ctx context.Context, in *pb.ContainersRequest) (*pb.ContainersReply, error)

CODE GENERATION 1 START

func (*ContainersEndpoint) Watch 

func (ed *ContainersEndpoint) Watch(in *pb.ContainersRequest, stream pb.Containers_WatchServer) error

type CoreinfoEndpoint 

type CoreinfoEndpoint struct {
	// contains filtered or unexported fields
}

func NewCoreinfoEndpoint 

func NewCoreinfoEndpoint(podgroupWatcher watcher.Watcher) *CoreinfoEndpoint

func (*CoreinfoEndpoint) Get 

func (ed *CoreinfoEndpoint) Get(ctx context.Context, in *pb.CoreinfoRequest) (*pb.CoreinfoReply, error)

CODE GENERATION 1 START

func (*CoreinfoEndpoint) Watch 

func (ed *CoreinfoEndpoint) Watch(in *pb.CoreinfoRequest, stream pb.Coreinfo_WatchServer) error

type DependsEndpoint 

type DependsEndpoint struct {
	// contains filtered or unexported fields
}

func NewDependsEndpoint 

func NewDependsEndpoint(dependsWatcher watcher.Watcher) *DependsEndpoint

func (*DependsEndpoint) Get 

func (ed *DependsEndpoint) Get(ctx context.Context, in *pb.DependsRequest) (*pb.DependsReply, error)

CODE GENERATION 1 START

func (*DependsEndpoint) Watch 

func (ed *DependsEndpoint) Watch(in *pb.DependsRequest, stream pb.Depends_WatchServer) error

type LainletEndpoint 

type LainletEndpoint struct {
	Name     string
	Watchers map[string]watcher.Watcher
}

func NewLainletEndpoint 

func NewLainletEndpoint(watchers map[string]watcher.Watcher) *LainletEndpoint

func (*LainletEndpoint) Status 

func (ed *LainletEndpoint) Status(ctx context.Context, in *pb.EmptyRequest) (*pb.StatusReply, error)

func (*LainletEndpoint) Version 

func (ed *LainletEndpoint) Version(ctx context.Context, in *pb.EmptyRequest) (*pb.VersionReply, error)

type LocalspecEndpoint 

type LocalspecEndpoint struct {
	// contains filtered or unexported fields
}

func NewLocalspecEndpoint 

func NewLocalspecEndpoint(containerWatcher watcher.Watcher, ip string) *LocalspecEndpoint

func (*LocalspecEndpoint) Get 

func (ed *LocalspecEndpoint) Get(ctx context.Context, in *pb.LocalspecRequest) (*pb.LocalspecReply, error)

type NodesEndpoint 

type NodesEndpoint struct {
	// contains filtered or unexported fields
}

func NewNodesEndpoint 

func NewNodesEndpoint(nodesWatcher watcher.Watcher) *NodesEndpoint

func (*NodesEndpoint) Get 

func (ed *NodesEndpoint) Get(ctx context.Context, in *pb.NodesRequest) (*pb.NodesReply, error)

CODE GENERATION 1 START

func (*NodesEndpoint) Watch 

func (ed *NodesEndpoint) Watch(in *pb.NodesRequest, stream pb.Nodes_WatchServer) error

type PodgroupEndpoint 

type PodgroupEndpoint struct {
	// contains filtered or unexported fields
}

func NewPodgroupEndpoint 

func NewPodgroupEndpoint(podgroupWatcher watcher.Watcher) *PodgroupEndpoint

func (*PodgroupEndpoint) Get 

func (ed *PodgroupEndpoint) Get(ctx context.Context, in *pb.PodgroupRequest) (*pb.PodgroupReply, error)

CODE GENERATION 1 START

func (*PodgroupEndpoint) Watch 

func (ed *PodgroupEndpoint) Watch(in *pb.PodgroupRequest, stream pb.Podgroup_WatchServer) error

type ProxyEndpoint 

type ProxyEndpoint struct {
	// contains filtered or unexported fields
}

func NewProxyEndpoint 

func NewProxyEndpoint(podgroupWatcher watcher.Watcher) *ProxyEndpoint

func (*ProxyEndpoint) Get 

func (ed *ProxyEndpoint) Get(ctx context.Context, in *pb.ProxyRequest) (*pb.ProxyReply, error)

CODE GENERATION 1 START

func (*ProxyEndpoint) Watch 

func (ed *ProxyEndpoint) Watch(in *pb.ProxyRequest, stream pb.Proxy_WatchServer) error

type RebellionLocalprocsEndpoint 

type RebellionLocalprocsEndpoint struct {
	// contains filtered or unexported fields
}

func NewRebellionLocalprocsEndpoint 

func NewRebellionLocalprocsEndpoint(podgroupWatcher watcher.Watcher) *RebellionLocalprocsEndpoint

func (*RebellionLocalprocsEndpoint) Get 

func (ed *RebellionLocalprocsEndpoint) Get(ctx context.Context, in *pb.RebellionLocalprocsRequest) (*pb.RebellionLocalprocsReply, error)

CODE GENERATION 1 START

func (*RebellionLocalprocsEndpoint) Watch 

func (ed *RebellionLocalprocsEndpoint) Watch(in *pb.RebellionLocalprocsRequest, stream pb.RebellionLocalprocs_WatchServer) error

type StreamrouterPortsEndpoint 

type StreamrouterPortsEndpoint struct {
	// contains filtered or unexported fields
}

func NewStreamrouterPortsEndpoint 

func NewStreamrouterPortsEndpoint(podgroupWatcher watcher.Watcher) *StreamrouterPortsEndpoint

func (*StreamrouterPortsEndpoint) Get 

func (ed *StreamrouterPortsEndpoint) Get(ctx context.Context, in *pb.StreamrouterPortsRequest) (*pb.StreamrouterPortsReply, error)

CODE GENERATION 1 START

func (*StreamrouterPortsEndpoint) Watch 

func (ed *StreamrouterPortsEndpoint) Watch(in *pb.StreamrouterPortsRequest, stream pb.StreamrouterPorts_WatchServer) error

type StreamrouterStreamprocsEndpoint 

type StreamrouterStreamprocsEndpoint struct {
	// contains filtered or unexported fields
}

func NewStreamrouterStreamprocsEndpoint 

func NewStreamrouterStreamprocsEndpoint(podgroupWatcher watcher.Watcher) *StreamrouterStreamprocsEndpoint

func (*StreamrouterStreamprocsEndpoint) Get 

func (ed *StreamrouterStreamprocsEndpoint) Get(ctx context.Context, in *pb.StreamrouterStreamprocsRequest) (*pb.StreamrouterStreamprocsReply, error)

CODE GENERATION 1 START

func (*StreamrouterStreamprocsEndpoint) Watch 

func (ed *StreamrouterStreamprocsEndpoint) Watch(in *pb.StreamrouterStreamprocsRequest, stream pb.StreamrouterStreamprocs_WatchServer) error

type WebrouterWebprocsEndpoint 

type WebrouterWebprocsEndpoint struct {
	// contains filtered or unexported fields
}

func NewWebrouterWebprocsEndpoint 

func NewWebrouterWebprocsEndpoint(podgroupWatcher watcher.Watcher) *WebrouterWebprocsEndpoint

func (*WebrouterWebprocsEndpoint) Get 

func (ed *WebrouterWebprocsEndpoint) Get(ctx context.Context, in *pb.WebrouterWebprocsRequest) (*pb.WebrouterWebprocsReply, error)

CODE GENERATION 1 START

func (*WebrouterWebprocsEndpoint) Watch 

func (ed *WebrouterWebprocsEndpoint) Watch(in *pb.WebrouterWebprocsRequest, stream pb.WebrouterWebprocs_WatchServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.