Documentation
¶
Index ¶
- func IsErrorUnrecoverable(err error) bool
- func NewKubeClient(kubeconfig string, logger *logrus.Logger) (clientset *kubernetes.Clientset, err error)
- type BundleIterator
- type BundleStream
- type Client
- func (c *Client) Close() error
- func (c *Client) GetBundle(ctx context.Context, packageName, channelName, csvName string) (*api.Bundle, error)
- func (c *Client) GetBundleInPackageChannel(ctx context.Context, packageName, channelName string) (*api.Bundle, error)
- func (c *Client) GetBundleThatProvides(ctx context.Context, group, version, kind string) (*api.Bundle, error)
- func (c *Client) GetPackage(ctx context.Context, packageName string) (*api.Package, error)
- func (c *Client) GetReplacementBundleInPackageChannel(ctx context.Context, currentName, packageName, channelName string) (*api.Bundle, error)
- func (c *Client) HealthCheck(ctx context.Context, reconnectTimeout time.Duration) (bool, error)
- func (c *Client) ListBundles(ctx context.Context) (*BundleIterator, error)
- type HealthError
- type HealthErrorReason
- type Interface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsErrorUnrecoverable ¶
IsErrorUnrecoverable reports if a given error is one of the predefined unrecoverable types
func NewKubeClient ¶
Types ¶
type BundleIterator ¶
type BundleIterator struct {
// contains filtered or unexported fields
}
func NewBundleIterator ¶
func NewBundleIterator(stream BundleStream) *BundleIterator
func (*BundleIterator) Error ¶
func (it *BundleIterator) Error() error
func (*BundleIterator) Next ¶
func (it *BundleIterator) Next() *api.Bundle
type BundleStream ¶
type Client ¶
type Client struct {
Registry api.RegistryClient
Health grpc_health_v1.HealthClient
Conn *grpc.ClientConn
}
func NewClientFromConn ¶
func NewClientFromConn(conn *grpc.ClientConn) *Client
func (*Client) GetBundleInPackageChannel ¶
func (*Client) GetBundleThatProvides ¶
func (*Client) GetPackage ¶
func (*Client) GetReplacementBundleInPackageChannel ¶
func (*Client) HealthCheck ¶
func (*Client) ListBundles ¶
func (c *Client) ListBundles(ctx context.Context) (*BundleIterator, error)
type HealthError ¶
type HealthError struct {
ClientState string
Reason HealthErrorReason
Message string
}
HealthError is used to represent error types for health checks
func NewHealthError ¶
func NewHealthError(conn *grpc.ClientConn, reason HealthErrorReason, msg string) HealthError
func (HealthError) Error ¶
func (e HealthError) Error() string
Error implements the Error interface.
type HealthErrorReason ¶
type HealthErrorReason string
const ( HealthErrReasonUnrecoveredTransient HealthErrorReason = "UnrecoveredTransient" HealthErrReasonConnection HealthErrorReason = "ConnectionError" HealthErrReasonUnknown HealthErrorReason = "Unknown" )
type Interface ¶
type Interface interface {
GetBundle(ctx context.Context, packageName, channelName, csvName string) (*api.Bundle, error)
GetBundleInPackageChannel(ctx context.Context, packageName, channelName string) (*api.Bundle, error)
GetReplacementBundleInPackageChannel(ctx context.Context, currentName, packageName, channelName string) (*api.Bundle, error)
GetBundleThatProvides(ctx context.Context, group, version, kind string) (*api.Bundle, error)
ListBundles(ctx context.Context) (*BundleIterator, error)
GetPackage(ctx context.Context, packageName string) (*api.Package, error)
HealthCheck(ctx context.Context, reconnectTimeout time.Duration) (bool, error)
Close() error
}
Source Files
Click to show internal directories.
Click to hide internal directories.