Documentation
¶
Index ¶
- type FilesystemPluginSyncServer
- func (f *FilesystemPluginSyncServer) CalculateExpectedManifest(_ context.Context, updateType urn.UpdateType) (*controlv1.UpdateManifest, error)
- func (f *FilesystemPluginSyncServer) CalculateUpdate(ctx context.Context, theirManifest *controlv1.UpdateManifest) (*controlv1.PatchList, error)
- func (f *FilesystemPluginSyncServer) Collectors() []prometheus.Collector
- func (f *FilesystemPluginSyncServer) RunGarbageCollection(ctx context.Context, store storage.ClusterStore) error
- func (f *FilesystemPluginSyncServer) Strategy() string
- type SyncServerOption
- type SyncServerOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FilesystemPluginSyncServer ¶
type FilesystemPluginSyncServer struct { controlv1.UnsafeUpdateSyncServer SyncServerOptions // contains filtered or unexported fields }
func NewFilesystemPluginSyncServer ¶
func NewFilesystemPluginSyncServer( cfg v1beta1.PluginsSpec, lg *zap.SugaredLogger, opts ...SyncServerOption, ) (*FilesystemPluginSyncServer, error)
func (*FilesystemPluginSyncServer) CalculateExpectedManifest ¶
func (f *FilesystemPluginSyncServer) CalculateExpectedManifest(_ context.Context, updateType urn.UpdateType) (*controlv1.UpdateManifest, error)
func (*FilesystemPluginSyncServer) CalculateUpdate ¶
func (f *FilesystemPluginSyncServer) CalculateUpdate( ctx context.Context, theirManifest *controlv1.UpdateManifest, ) (*controlv1.PatchList, error)
func (*FilesystemPluginSyncServer) Collectors ¶
func (f *FilesystemPluginSyncServer) Collectors() []prometheus.Collector
func (*FilesystemPluginSyncServer) RunGarbageCollection ¶
func (f *FilesystemPluginSyncServer) RunGarbageCollection(ctx context.Context, store storage.ClusterStore) error
func (*FilesystemPluginSyncServer) Strategy ¶
func (f *FilesystemPluginSyncServer) Strategy() string
type SyncServerOption ¶
type SyncServerOption func(*SyncServerOptions)
func WithFs ¶
func WithFs(fsys afero.Fs) SyncServerOption
func WithPluginSyncFilters ¶
func WithPluginSyncFilters(filters plugins.Filter) SyncServerOption
type SyncServerOptions ¶
type SyncServerOptions struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.