qlight

Oct 22, 2024

Changes in this version

+ const ConnectorName

+ type MockPluginTokenManager struct

+ func NewMockPluginTokenManager(ctrl *gomock.Controller) *MockPluginTokenManager

+ func (m *MockPluginTokenManager) EXPECT() *MockPluginTokenManagerMockRecorder

+ func (m *MockPluginTokenManager) PluginTokenManager(ctx context.Context) (int32, error)

+ func (m *MockPluginTokenManager) TokenRefresh(ctx context.Context, currentToken, psi string) (string, error)

+ type MockPluginTokenManagerMockRecorder struct

+ func (mr *MockPluginTokenManagerMockRecorder) PluginTokenManager(ctx interface{}) *gomock.Call

+ func (mr *MockPluginTokenManagerMockRecorder) TokenRefresh(ctx, currentToken, psi interface{}) *gomock.Call

+ type PluginConnector struct

+ func (p *PluginConnector) GRPCClient(ctx context.Context, b *plugin.GRPCBroker, cc *grpc.ClientConn) (interface{}, error)

+ func (p *PluginConnector) GRPCServer(b *plugin.GRPCBroker, s *grpc.Server) error

+ type PluginGateway struct

+ func (p *PluginGateway) PluginTokenManager(ctx context.Context) (int32, error)

+ func (p *PluginGateway) TokenRefresh(ctx context.Context, currentToken, psi string) (string, error)

+ type PluginTokenManager interface

+ PluginTokenManager func(ctx context.Context) (int32, error)

+ TokenRefresh func(ctx context.Context, currentToken, psi string) (string, error)

+ type PluginTokenManagerDeferFunc func() (PluginTokenManager, error)

+ type ReloadablePluginTokenManager struct

+ DeferFunc PluginTokenManagerDeferFunc

+ func (d *ReloadablePluginTokenManager) PluginTokenManager(ctx context.Context) (int32, error)

+ func (d *ReloadablePluginTokenManager) TokenRefresh(ctx context.Context, currentToken, psi string) (string, error)