common

package

Go to main page

Versions in this module

v0

v0.13.1

Oct 15, 2024

v0.13.0

Jul 8, 2024

v0.12.2

May 23, 2024

v0.12.1

Nov 9, 2023

v0.12.0

Jul 24, 2023

v0.11.0

Feb 14, 2023

Changes in this version

+ var Logger_ServiceDesc = grpc.ServiceDesc

+ var ProviderPlugin_ServiceDesc = grpc.ServiceDesc

+ func RegisterProviderPluginServer(s grpc.ServiceRegistrar, srv ProviderPluginServer)

type GRPCClient

+ func (c *GRPCClient) Invalidate()

+ func (c *GRPCClient) Keep()

+ func (c *GRPCClient) SetCacheDir(dir string)

+ func (c *GRPCClient) SetDataDir(dir string) error

+ func (c *GRPCClient) SetLogger(logger Logger) error

type GRPCLoggerClient

+ func (c *GRPCLoggerClient) Fire(entry *logrus.Entry) error

+ func (c *GRPCLoggerClient) Levels() []logrus.Level

type GRPCServer

+ func (s *GRPCServer) Invalidate(ctx context.Context, req *Empty) (*Empty, error)

+ func (s *GRPCServer) Keep(ctx context.Context, req *Empty) (*Empty, error)

+ func (s *GRPCServer) SetCacheDir(ctx context.Context, req *SetCacheDirRequest) (*Empty, error)

+ func (s *GRPCServer) SetDataDir(ctx context.Context, req *SetDataDirRequest) (*SetDataDirResponse, error)

+ func (s *GRPCServer) SetLogger(ctx context.Context, req *SetLoggerRequest) (*SetLoggerResponse, error)

+ type ProviderPluginClient interface

+ Configure func(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)

+ Invalidate func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ Keep func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ Load func(ctx context.Context, in *LoadRequest, opts ...grpc.CallOption) (*LoadResponse, error)

+ SetCacheDir func(ctx context.Context, in *SetCacheDirRequest, opts ...grpc.CallOption) (*Empty, error)

+ SetDataDir func(ctx context.Context, in *SetDataDirRequest, opts ...grpc.CallOption) (*SetDataDirResponse, error)

+ SetLogger func(ctx context.Context, in *SetLoggerRequest, opts ...grpc.CallOption) (*SetLoggerResponse, error)

+ func NewProviderPluginClient(cc grpc.ClientConnInterface) ProviderPluginClient

+ type ProviderPluginImpl interface

+ Configure func(map[string]interface{}) error

+ Invalidate func()

+ Keep func()

+ Load func(ctx context.Context) (*herd.HostSet, error)

+ SetCacheDir func(string)

+ SetDataDir func(string) error

+ SetLogger func(Logger) error

+ type ProviderPluginServer interface

+ Configure func(context.Context, *ConfigureRequest) (*ConfigureResponse, error)

+ Invalidate func(context.Context, *Empty) (*Empty, error)

+ Keep func(context.Context, *Empty) (*Empty, error)

+ Load func(context.Context, *LoadRequest) (*LoadResponse, error)

+ SetCacheDir func(context.Context, *SetCacheDirRequest) (*Empty, error)

+ SetDataDir func(context.Context, *SetDataDirRequest) (*SetDataDirResponse, error)

+ SetLogger func(context.Context, *SetLoggerRequest) (*SetLoggerResponse, error)

+ type SetCacheDirRequest struct

+ Dir string

+ func (*SetCacheDirRequest) Descriptor() ([]byte, []int)

+ func (*SetCacheDirRequest) ProtoMessage()

+ func (x *SetCacheDirRequest) GetDir() string

+ func (x *SetCacheDirRequest) ProtoReflect() protoreflect.Message

+ func (x *SetCacheDirRequest) Reset()

+ func (x *SetCacheDirRequest) String() string

+ type SetDataDirRequest struct

+ Dir string

+ func (*SetDataDirRequest) Descriptor() ([]byte, []int)

+ func (*SetDataDirRequest) ProtoMessage()

+ func (x *SetDataDirRequest) GetDir() string

+ func (x *SetDataDirRequest) ProtoReflect() protoreflect.Message

+ func (x *SetDataDirRequest) Reset()

+ func (x *SetDataDirRequest) String() string

+ type SetDataDirResponse struct

+ Err string

+ func (*SetDataDirResponse) Descriptor() ([]byte, []int)

+ func (*SetDataDirResponse) ProtoMessage()

+ func (x *SetDataDirResponse) GetErr() string

+ func (x *SetDataDirResponse) ProtoReflect() protoreflect.Message

+ func (x *SetDataDirResponse) Reset()

+ func (x *SetDataDirResponse) String() string

+ type SetLoggerRequest struct

+ Logger uint32

+ func (*SetLoggerRequest) Descriptor() ([]byte, []int)

+ func (*SetLoggerRequest) ProtoMessage()

+ func (x *SetLoggerRequest) GetLogger() uint32

+ func (x *SetLoggerRequest) ProtoReflect() protoreflect.Message

+ func (x *SetLoggerRequest) Reset()

+ func (x *SetLoggerRequest) String() string

+ type SetLoggerResponse struct

+ Err string

+ func (*SetLoggerResponse) Descriptor() ([]byte, []int)

+ func (*SetLoggerResponse) ProtoMessage()

+ func (x *SetLoggerResponse) GetErr() string

+ func (x *SetLoggerResponse) ProtoReflect() protoreflect.Message

+ func (x *SetLoggerResponse) Reset()

+ func (x *SetLoggerResponse) String() string

+ type UnimplementedProviderPluginServer struct

+ func (UnimplementedProviderPluginServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)

+ func (UnimplementedProviderPluginServer) Invalidate(context.Context, *Empty) (*Empty, error)

+ func (UnimplementedProviderPluginServer) Keep(context.Context, *Empty) (*Empty, error)

+ func (UnimplementedProviderPluginServer) Load(context.Context, *LoadRequest) (*LoadResponse, error)

+ func (UnimplementedProviderPluginServer) SetCacheDir(context.Context, *SetCacheDirRequest) (*Empty, error)

+ func (UnimplementedProviderPluginServer) SetDataDir(context.Context, *SetDataDirRequest) (*SetDataDirResponse, error)

+ func (UnimplementedProviderPluginServer) SetLogger(context.Context, *SetLoggerRequest) (*SetLoggerResponse, error)

+ type UnsafeProviderPluginServer interface

v0.10.0

Dec 8, 2022

v0.9.1

Sep 24, 2022

v0.9.0

Sep 24, 2022

v0.8.1

Mar 10, 2022

Changes in this version

+ var File_provider_plugin_common_plugin_proto protoreflect.FileDescriptor

+ var Handshake = plugin.HandshakeConfig

+ func NewLogrusLogger(l *logrus.Logger, name string) *logrusLogger

+ func RegisterLoggerServer(s grpc.ServiceRegistrar, srv LoggerServer)

+ func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer)

+ type ConfigureRequest struct

+ Data []byte

+ func (*ConfigureRequest) Descriptor() ([]byte, []int)

+ func (*ConfigureRequest) ProtoMessage()

+ func (x *ConfigureRequest) GetData() []byte

+ func (x *ConfigureRequest) ProtoReflect() protoreflect.Message

+ func (x *ConfigureRequest) Reset()

+ func (x *ConfigureRequest) String() string

+ type ConfigureResponse struct

+ Err string

+ func (*ConfigureResponse) Descriptor() ([]byte, []int)

+ func (*ConfigureResponse) ProtoMessage()

+ func (x *ConfigureResponse) GetErr() string

+ func (x *ConfigureResponse) ProtoReflect() protoreflect.Message

+ func (x *ConfigureResponse) Reset()

+ func (x *ConfigureResponse) String() string

+ type EmitLogMessageRequest struct

+ Level uint32

+ Message string

+ func (*EmitLogMessageRequest) Descriptor() ([]byte, []int)

+ func (*EmitLogMessageRequest) ProtoMessage()

+ func (x *EmitLogMessageRequest) GetLevel() uint32

+ func (x *EmitLogMessageRequest) GetMessage() string

+ func (x *EmitLogMessageRequest) ProtoReflect() protoreflect.Message

+ func (x *EmitLogMessageRequest) Reset()

+ func (x *EmitLogMessageRequest) String() string

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type GRPCClient struct

+ func (c *GRPCClient) Configure(settings map[string]interface{}) error

+ func (c *GRPCClient) Load(ctx context.Context, logger Logger) (herd.Hosts, error)

+ type GRPCLoggerClient struct

+ func (c *GRPCLoggerClient) EmitLogMessage(level logrus.Level, message string)

+ func (c *GRPCLoggerClient) LoadingMessage(name string, done bool, err error)

+ type GRPCLoggerServer struct

+ Impl Logger

+ func (s *GRPCLoggerServer) EmitLogMessage(ctx context.Context, req *EmitLogMessageRequest) (*Empty, error)

+ func (s *GRPCLoggerServer) LoadingMessage(ctx context.Context, req *LoadingMessageRequest) (*Empty, error)

+ type GRPCServer struct

+ Impl Provider

+ func (s *GRPCServer) Configure(ctx context.Context, req *ConfigureRequest) (*ConfigureResponse, error)

+ func (s *GRPCServer) Load(ctx context.Context, req *LoadRequest) (*LoadResponse, error)

+ type LoadRequest struct

+ Deadline *timestamppb.Timestamp

+ Logger uint32

+ func (*LoadRequest) Descriptor() ([]byte, []int)

+ func (*LoadRequest) ProtoMessage()

+ func (x *LoadRequest) GetDeadline() *timestamppb.Timestamp

+ func (x *LoadRequest) GetLogger() uint32

+ func (x *LoadRequest) ProtoReflect() protoreflect.Message

+ func (x *LoadRequest) Reset()

+ func (x *LoadRequest) String() string

+ type LoadResponse struct

+ Data []byte

+ Err string

+ func (*LoadResponse) Descriptor() ([]byte, []int)

+ func (*LoadResponse) ProtoMessage()

+ func (x *LoadResponse) GetData() []byte

+ func (x *LoadResponse) GetErr() string

+ func (x *LoadResponse) ProtoReflect() protoreflect.Message

+ func (x *LoadResponse) Reset()

+ func (x *LoadResponse) String() string

+ type LoadingMessageRequest struct

+ Done bool

+ Err string

+ Name string

+ func (*LoadingMessageRequest) Descriptor() ([]byte, []int)

+ func (*LoadingMessageRequest) ProtoMessage()

+ func (x *LoadingMessageRequest) GetDone() bool

+ func (x *LoadingMessageRequest) GetErr() string

+ func (x *LoadingMessageRequest) GetName() string

+ func (x *LoadingMessageRequest) ProtoReflect() protoreflect.Message

+ func (x *LoadingMessageRequest) Reset()

+ func (x *LoadingMessageRequest) String() string

+ type Logger interface

+ EmitLogMessage func(level logrus.Level, message string)

+ LoadingMessage func(name string, done bool, err error)

+ type LoggerClient interface

+ EmitLogMessage func(ctx context.Context, in *EmitLogMessageRequest, opts ...grpc.CallOption) (*Empty, error)

+ LoadingMessage func(ctx context.Context, in *LoadingMessageRequest, opts ...grpc.CallOption) (*Empty, error)

+ func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient

+ type LoggerServer interface

+ EmitLogMessage func(context.Context, *EmitLogMessageRequest) (*Empty, error)

+ LoadingMessage func(context.Context, *LoadingMessageRequest) (*Empty, error)

+ type Provider interface

+ Configure func(map[string]interface{}) error

+ Load func(ctx context.Context, logger Logger) (herd.Hosts, error)

+ type ProviderClient interface

+ Configure func(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)

+ Load func(ctx context.Context, in *LoadRequest, opts ...grpc.CallOption) (*LoadResponse, error)

+ func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient

+ type ProviderPlugin struct

+ Impl Provider

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

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

+ type ProviderServer interface

+ Configure func(context.Context, *ConfigureRequest) (*ConfigureResponse, error)

+ Load func(context.Context, *LoadRequest) (*LoadResponse, error)

+ type UnimplementedLoggerServer struct

+ func (UnimplementedLoggerServer) EmitLogMessage(context.Context, *EmitLogMessageRequest) (*Empty, error)

+ func (UnimplementedLoggerServer) LoadingMessage(context.Context, *LoadingMessageRequest) (*Empty, error)

+ type UnimplementedProviderServer struct

+ func (UnimplementedProviderServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)

+ func (UnimplementedProviderServer) Load(context.Context, *LoadRequest) (*LoadResponse, error)

+ type UnsafeLoggerServer interface

+ type UnsafeProviderServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL