Versions in this module Expand all Collapse all v0 v0.1.1 Apr 2, 2025 Changes in this version + type ClientPlugin interface + ModifyClientOptions func([]grpc.DialOption) []grpc.DialOption + type InterceptorPlugin interface + StreamClientInterceptor func() grpc.StreamClientInterceptor + StreamServerInterceptor func() grpc.StreamServerInterceptor + UnaryClientInterceptor func() grpc.UnaryClientInterceptor + UnaryServerInterceptor func() grpc.UnaryServerInterceptor + type LifecycleHook interface + AfterStart func(context.Context) error + AfterStop func(context.Context) error + BeforeStart func(context.Context) error + BeforeStop func(context.Context) error + type LifecycleManager struct + func NewLifecycleManager(manager *Manager) *LifecycleManager + func (lm *LifecycleManager) ExecuteAfterStart(ctx context.Context) error + func (lm *LifecycleManager) ExecuteAfterStop(ctx context.Context) error + func (lm *LifecycleManager) ExecuteBeforeStart(ctx context.Context) error + func (lm *LifecycleManager) ExecuteBeforeStop(ctx context.Context) error + type Manager struct + func NewManager() *Manager + func (m *Manager) ApplyClientPlugins(opts []grpc.DialOption) []grpc.DialOption + func (m *Manager) ApplyServerPlugins(server *grpc.Server) error + func (m *Manager) Close() error + func (m *Manager) Get(name string) (Plugin, bool) + func (m *Manager) GetAll() []Plugin + func (m *Manager) GetByType(pluginType interface{}) []Plugin + func (m *Manager) GetInterceptors() (unaryServer []grpc.UnaryServerInterceptor, ...) + func (m *Manager) Init() error + func (m *Manager) Register(p Plugin) error + type Plugin interface + Close func() error + Init func() error + Name func() string + type ServerPlugin interface + RegisterWithServer func(*grpc.Server) error
Go to main page