redis

package

v0.8.0 Latest Latest Go to latest Published: Mar 24, 2025 License: Apache-2.0 Imports: 12 Imported by: 2

Details

View Source

const (
	DefaultDialTimeout     = 15 * time.Second
	DefaultConnMaxIdleTime = 3 * time.Second
	DefaultPoolSize        = 1
)

This section is empty.

This section is empty.

type Client struct {
	*rd.Client
}

type ClusterClient struct {
	*rd.ClusterClient
}

type KubeDBClientBuilder struct {
	// contains filtered or unexported fields
}

func NewKubeDBClientBuilder(kc client.Client, db *dbapi.Redis) *KubeDBClientBuilder

func (o *KubeDBClientBuilder) GetRedisClient(ctx context.Context) (*Client, error)

func (o *KubeDBClientBuilder) GetRedisClusterClient(ctx context.Context) (*ClusterClient, error)

func (o *KubeDBClientBuilder) WithDatabase(database int) *KubeDBClientBuilder

func (o *KubeDBClientBuilder) WithPod(podName string) *KubeDBClientBuilder

func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder