Documentation
¶
Index ¶
- type DummyPluginManager
- func (s *DummyPluginManager) Get(_ context.Context, _ string) (entities.Plugin, error)
- func (s *DummyPluginManager) GetAll(_ context.Context) ([]entities.Plugin, []time.Time)
- func (s *DummyPluginManager) HeartBeat(_ context.Context, _ string) error
- func (s *DummyPluginManager) Ready() bool
- func (s *DummyPluginManager) RefreshToken(_ context.Context, _ *entities.AuthPlugin, _ string) (*entities.ClientToken, error)
- func (s *DummyPluginManager) Register(_ context.Context, _ *entities.Plugin) (*entities.ClientToken, error)
- func (s *DummyPluginManager) StartCleanup(_ context.Context)
- func (s *DummyPluginManager) Unregister(_ context.Context, _ string)
- type PluginManager
- func (p *PluginManager) Get(ctx context.Context, slug string) (entities.Plugin, error)
- func (p *PluginManager) GetAll(_ context.Context) ([]entities.Plugin, []time.Time)
- func (p *PluginManager) HeartBeat(ctx context.Context, slug string) error
- func (p *PluginManager) Ready() bool
- func (p *PluginManager) RefreshToken(ctx context.Context, auth *entities.AuthPlugin, slug string) (*entities.ClientToken, error)
- func (p *PluginManager) Register(ctx context.Context, plugin *entities.Plugin) (*entities.ClientToken, error)
- func (p *PluginManager) StartCleanup(ctx context.Context)
- func (p *PluginManager) Unregister(ctx context.Context, slug string)
- type PluginManagerConfig
- type PluginManagerOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DummyPluginManager ¶
type DummyPluginManager struct{}
DummyPluginManager is used to disable the plugin service
func NewDummyPluginManager ¶
func NewDummyPluginManager() *DummyPluginManager
func (*DummyPluginManager) HeartBeat ¶
func (s *DummyPluginManager) HeartBeat(_ context.Context, _ string) error
func (*DummyPluginManager) Ready ¶
func (s *DummyPluginManager) Ready() bool
func (*DummyPluginManager) RefreshToken ¶
func (s *DummyPluginManager) RefreshToken(_ context.Context, _ *entities.AuthPlugin, _ string) (*entities.ClientToken, error)
func (*DummyPluginManager) Register ¶
func (s *DummyPluginManager) Register(_ context.Context, _ *entities.Plugin) (*entities.ClientToken, error)
func (*DummyPluginManager) StartCleanup ¶
func (s *DummyPluginManager) StartCleanup(_ context.Context)
func (*DummyPluginManager) Unregister ¶
func (s *DummyPluginManager) Unregister(_ context.Context, _ string)
type PluginManager ¶
type PluginManager struct {
PluginManagerConfig
// contains filtered or unexported fields
}
func NewPluginManager ¶
func NewPluginManager(authRepo storage.AuthRepository, opts ...PluginManagerOption) *PluginManager
func (*PluginManager) HeartBeat ¶
func (p *PluginManager) HeartBeat(ctx context.Context, slug string) error
func (*PluginManager) Ready ¶
func (p *PluginManager) Ready() bool
func (*PluginManager) RefreshToken ¶
func (p *PluginManager) RefreshToken(ctx context.Context, auth *entities.AuthPlugin, slug string) (*entities.ClientToken, error)
func (*PluginManager) Register ¶
func (p *PluginManager) Register(ctx context.Context, plugin *entities.Plugin) (*entities.ClientToken, error)
func (*PluginManager) StartCleanup ¶
func (p *PluginManager) StartCleanup(ctx context.Context)
func (*PluginManager) Unregister ¶
func (p *PluginManager) Unregister(ctx context.Context, slug string)
type PluginManagerConfig ¶
type PluginManagerConfig struct {
// contains filtered or unexported fields
}
type PluginManagerOption ¶
type PluginManagerOption func(*PluginManagerConfig)
func WithInterval ¶
func WithInterval(interval time.Duration) PluginManagerOption
func WithTimeout ¶
func WithTimeout(timeout time.Duration) PluginManagerOption
Source Files
Click to show internal directories.
Click to hide internal directories.