Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigurationStream ¶
type ConfigurationStream interface {
Send(req *pb.GetConfigurationUpdatesRequest) error
Recv() (*pb.GetConfigurationUpdatesResponse, error)
}
ConfigurationStream abstracts the GetConfigurationUpdates gRPC stream.
type Factory ¶
type Factory struct {
Logger *zap.Logger
VerboseDebugging bool
BufferedGrpcSyncer *logging.BufferedGrpcWriteSyncer
}
Factory creates configuration stream clients.
func (*Factory) NewStreamClient ¶
func (f *Factory) NewStreamClient(ctx context.Context, grpcConn grpc.ClientConnInterface) (stream.StreamClient, error)
NewStreamClient creates a new configuration stream client.
Source Files
Click to show internal directories.
Click to hide internal directories.