redis

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 14, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// String operations
	RedisIntegrationActionType_Get    domain.IntegrationActionType = "get"
	RedisIntegrationActionType_Set    domain.IntegrationActionType = "set"
	RedisIntegrationActionType_Del    domain.IntegrationActionType = "del"
	RedisIntegrationActionType_Exists domain.IntegrationActionType = "exists"
	RedisIntegrationActionType_Incr   domain.IntegrationActionType = "incr"
	RedisIntegrationActionType_Decr   domain.IntegrationActionType = "decr"
	RedisIntegrationActionType_Append domain.IntegrationActionType = "append"
	RedisIntegrationActionType_Strlen domain.IntegrationActionType = "strlen"

	// Hash operations
	RedisIntegrationActionType_HGet    domain.IntegrationActionType = "hget"
	RedisIntegrationActionType_HSet    domain.IntegrationActionType = "hset"
	RedisIntegrationActionType_HDel    domain.IntegrationActionType = "hdel"
	RedisIntegrationActionType_HExists domain.IntegrationActionType = "hexists"
	RedisIntegrationActionType_HGetAll domain.IntegrationActionType = "hgetall"
	RedisIntegrationActionType_HKeys   domain.IntegrationActionType = "hkeys"
	RedisIntegrationActionType_HVals   domain.IntegrationActionType = "hvals"
	RedisIntegrationActionType_HLen    domain.IntegrationActionType = "hlen"

	// List operations
	RedisIntegrationActionType_LPush  domain.IntegrationActionType = "lpush"
	RedisIntegrationActionType_RPush  domain.IntegrationActionType = "rpush"
	RedisIntegrationActionType_LPop   domain.IntegrationActionType = "lpop"
	RedisIntegrationActionType_RPop   domain.IntegrationActionType = "rpop"
	RedisIntegrationActionType_LLen   domain.IntegrationActionType = "llen"
	RedisIntegrationActionType_LRange domain.IntegrationActionType = "lrange"
	RedisIntegrationActionType_LIndex domain.IntegrationActionType = "lindex"
	RedisIntegrationActionType_LSet   domain.IntegrationActionType = "lset"

	// Set operations
	RedisIntegrationActionType_SAdd      domain.IntegrationActionType = "sadd"
	RedisIntegrationActionType_SRem      domain.IntegrationActionType = "srem"
	RedisIntegrationActionType_SMembers  domain.IntegrationActionType = "smembers"
	RedisIntegrationActionType_SIsMember domain.IntegrationActionType = "sismember"
	RedisIntegrationActionType_SCard     domain.IntegrationActionType = "scard"
	RedisIntegrationActionType_SPop      domain.IntegrationActionType = "spop"

	// Sorted Set operations
	RedisIntegrationActionType_ZAdd             domain.IntegrationActionType = "zadd"
	RedisIntegrationActionType_ZRem             domain.IntegrationActionType = "zrem"
	RedisIntegrationActionType_ZRange           domain.IntegrationActionType = "zrange"
	RedisIntegrationActionType_ZRevRange        domain.IntegrationActionType = "zrevrange"
	RedisIntegrationActionType_ZRangeByScore    domain.IntegrationActionType = "zrangebyscore"
	RedisIntegrationActionType_ZRevRangeByScore domain.IntegrationActionType = "zrevrangebyscore"
	RedisIntegrationActionType_ZCard            domain.IntegrationActionType = "zcard"
	RedisIntegrationActionType_ZScore           domain.IntegrationActionType = "zscore"
	RedisIntegrationActionType_ZRank            domain.IntegrationActionType = "zrank"

	// Key management
	RedisIntegrationActionType_Keys    domain.IntegrationActionType = "keys"
	RedisIntegrationActionType_Expire  domain.IntegrationActionType = "expire"
	RedisIntegrationActionType_TTL     domain.IntegrationActionType = "ttl"
	RedisIntegrationActionType_Type    domain.IntegrationActionType = "type"
	RedisIntegrationActionType_Rename  domain.IntegrationActionType = "rename"
	RedisIntegrationActionType_Persist domain.IntegrationActionType = "persist"

	// AI Agent Memory
	RedisIntegrationActionType_UseMemory domain.IntegrationActionType = "redis_agent_use_memory"

	// Peekable types
	RedisIntegrationPeekable_Keys      domain.IntegrationPeekableType = "keys"
	RedisIntegrationPeekable_Databases domain.IntegrationPeekableType = "databases"
)

Variables

View Source 
var (
	Schema = schema
)

Functions

func NewRedisConnectionTester 

func NewRedisConnectionTester(deps domain.IntegrationDeps) domain.IntegrationConnectionTester

func NewRedisIntegrationCreator 

func NewRedisIntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator

Types

type AppendParams 

type AppendParams struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type DecrParams 

type DecrParams struct {
	Key string `json:"key"`
}

type DelParams 

type DelParams struct {
	Keys []string `json:"keys"`
}

type ExistsParams 

type ExistsParams struct {
	Keys []string `json:"keys"`
}

type ExpireParams 

type ExpireParams struct {
	Key        string `json:"key"`
	Expiration int    `json:"expiration"` // seconds
}

type GetParams 

type GetParams struct {
	Key string `json:"key"`
}

type GetResult 

type GetResult struct {
	Key   string  `json:"key"`
	Value *string `json:"value"`
	Found bool    `json:"found"`
}

type HDelParams 

type HDelParams struct {
	Key    string   `json:"key"`
	Fields []string `json:"fields"`
}

type HExistsParams 

type HExistsParams struct {
	Key   string `json:"key"`
	Field string `json:"field"`
}

type HGetAllParams 

type HGetAllParams struct {
	Key string `json:"key"`
}

type HGetParams 

type HGetParams struct {
	Key   string `json:"key"`
	Field string `json:"field"`
}

type HKeysParams 

type HKeysParams struct {
	Key string `json:"key"`
}

type HLenParams 

type HLenParams struct {
	Key string `json:"key"`
}

type HSetParams 

type HSetParams struct {
	Key        string `json:"key"`
	FieldsJSON string `json:"fields"`
}

type HValsParams 

type HValsParams struct {
	Key string `json:"key"`
}

type IncrParams 

type IncrParams struct {
	Key string `json:"key"`
}

type KeysParams 

type KeysParams struct {
	Pattern string `json:"pattern"`
}

type LIndexParams 

type LIndexParams struct {
	Key   string `json:"key"`
	Index int64  `json:"index"`
}

type LLenParams 

type LLenParams struct {
	Key string `json:"key"`
}

type LPopParams 

type LPopParams struct {
	Key   string `json:"key"`
	Count int    `json:"count,omitempty"` // Default 1
}

type LPushParams 

type LPushParams struct {
	Key    string   `json:"key"`
	Values []string `json:"values"`
}

type LRangeParams 

type LRangeParams struct {
	Key   string `json:"key"`
	Start int64  `json:"start"`
	Stop  int64  `json:"stop"`
}

type LSetParams 

type LSetParams struct {
	Key   string `json:"key"`
	Index int64  `json:"index"`
	Value string `json:"value"`
}

type PersistParams 

type PersistParams struct {
	Key string `json:"key"`
}

type RPopParams 

type RPopParams struct {
	Key   string `json:"key"`
	Count int    `json:"count,omitempty"` // Default 1
}

type RPushParams 

type RPushParams struct {
	Key    string   `json:"key"`
	Values []string `json:"values"`
}

type RedisConnectionTester 

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

func (*RedisConnectionTester) TestConnection 

func (c *RedisConnectionTester) TestConnection(ctx context.Context, params domain.TestConnectionParams) (bool, error)

type RedisCredential 

type RedisCredential struct {
	Host          string `json:"host"`
	Port          string `json:"port"`
	Password      string `json:"password"`
	Database      string `json:"database"`
	Username      string `json:"username"`
	TLS           bool   `json:"tls"`
	TLSSkipVerify bool   `json:"tls_skip_verify,omitempty"`
	TLSServerName string `json:"tls_server_name,omitempty"`
}

type RedisIntegration 

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

func NewRedisIntegration 

func NewRedisIntegration(ctx context.Context, deps RedisIntegrationDependencies) (*RedisIntegration, error)

func (*RedisIntegration) Append 

func (i *RedisIntegration) Append(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Decr 

func (i *RedisIntegration) Decr(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Del 

func (i *RedisIntegration) Del(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Execute 

func (i *RedisIntegration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)

func (*RedisIntegration) Exists 

func (i *RedisIntegration) Exists(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Expire 

func (i *RedisIntegration) Expire(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Get 

func (i *RedisIntegration) Get(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HDel 

func (i *RedisIntegration) HDel(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HExists 

func (i *RedisIntegration) HExists(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HGet 

func (i *RedisIntegration) HGet(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HGetAll 

func (i *RedisIntegration) HGetAll(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HKeys 

func (i *RedisIntegration) HKeys(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HLen 

func (i *RedisIntegration) HLen(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HSet 

func (i *RedisIntegration) HSet(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) HVals 

func (i *RedisIntegration) HVals(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Incr 

func (i *RedisIntegration) Incr(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Keys 

func (i *RedisIntegration) Keys(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LIndex 

func (i *RedisIntegration) LIndex(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LLen 

func (i *RedisIntegration) LLen(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LPop 

func (i *RedisIntegration) LPop(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LPush 

func (i *RedisIntegration) LPush(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LRange 

func (i *RedisIntegration) LRange(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) LSet 

func (i *RedisIntegration) LSet(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Peek 

func (i *RedisIntegration) Peek(ctx context.Context, params domain.PeekParams) (domain.PeekResult, error)

func (*RedisIntegration) Persist 

func (i *RedisIntegration) Persist(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) RPop 

func (i *RedisIntegration) RPop(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) RPush 

func (i *RedisIntegration) RPush(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Rename 

func (i *RedisIntegration) Rename(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) RetrieveConversations 

func (i *RedisIntegration) RetrieveConversations(ctx context.Context, filter domain.ConversationFilter) ([]domain.AgentConversation, error)

func (*RedisIntegration) SAdd 

func (i *RedisIntegration) SAdd(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) SCard 

func (i *RedisIntegration) SCard(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) SIsMember 

func (i *RedisIntegration) SIsMember(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) SMembers 

func (i *RedisIntegration) SMembers(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) SPop 

func (i *RedisIntegration) SPop(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) SRem 

func (i *RedisIntegration) SRem(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Set 

func (i *RedisIntegration) Set(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) StoreConversation 

func (i *RedisIntegration) StoreConversation(ctx context.Context, request domain.StoreConversationRequest) error

func (*RedisIntegration) Strlen 

func (i *RedisIntegration) Strlen(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) TTL 

func (i *RedisIntegration) TTL(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) Type 

func (i *RedisIntegration) Type(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZAdd 

func (i *RedisIntegration) ZAdd(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZCard 

func (i *RedisIntegration) ZCard(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRange 

func (i *RedisIntegration) ZRange(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRangeByScore 

func (i *RedisIntegration) ZRangeByScore(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRank 

func (i *RedisIntegration) ZRank(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRem 

func (i *RedisIntegration) ZRem(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRevRange 

func (i *RedisIntegration) ZRevRange(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZRevRangeByScore 

func (i *RedisIntegration) ZRevRangeByScore(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

func (*RedisIntegration) ZScore 

func (i *RedisIntegration) ZScore(ctx context.Context, input domain.IntegrationInput, item domain.Item) (domain.Item, error)

type RedisIntegrationCreator 

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

func (*RedisIntegrationCreator) CreateIntegration 

func (c *RedisIntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)

type RedisIntegrationDependencies 

type RedisIntegrationDependencies struct {
	CredentialID     string
	CredentialGetter domain.CredentialGetter[RedisCredential]
	ParameterBinder  domain.IntegrationParameterBinder
}

type RenameParams 

type RenameParams struct {
	OldKey string `json:"old_key"`
	NewKey string `json:"new_key"`
}

type SAddParams 

type SAddParams struct {
	Key     string   `json:"key"`
	Members []string `json:"members"`
}

type SCardParams 

type SCardParams struct {
	Key string `json:"key"`
}

type SIsMemberParams 

type SIsMemberParams struct {
	Key    string `json:"key"`
	Member string `json:"member"`
}

type SMembersParams 

type SMembersParams struct {
	Key string `json:"key"`
}

type SPopParams 

type SPopParams struct {
	Key   string `json:"key"`
	Count int64  `json:"count,omitempty"` // Default 1
}

type SRemParams 

type SRemParams struct {
	Key     string   `json:"key"`
	Members []string `json:"members"`
}

type SetParams 

type SetParams struct {
	Key        string `json:"key"`
	Value      string `json:"value"`
	Expiration int    `json:"expiration,omitempty"` // seconds
}

type StrlenParams 

type StrlenParams struct {
	Key string `json:"key"`
}

type TTLParams 

type TTLParams struct {
	Key string `json:"key"`
}

type TypeParams 

type TypeParams struct {
	Key string `json:"key"`
}

type ZAddParams 

type ZAddParams struct {
	Key     string    `json:"key"`
	Members []redis.Z `json:"members"`
}

type ZAddParamsInput 

type ZAddParamsInput struct {
	Key     string    `json:"key"`
	Members []ZMember `json:"members"`
}

type ZCardParams 

type ZCardParams struct {
	Key string `json:"key"`
}

type ZMember 

type ZMember struct {
	Score  float64 `json:"score"`
	Member string  `json:"member"`
}

type ZRangeByScoreParams 

type ZRangeByScoreParams struct {
	Key string `json:"key"`
	Min string `json:"min"`
	Max string `json:"max"`
}

type ZRangeParams 

type ZRangeParams struct {
	Key   string `json:"key"`
	Start int64  `json:"start"`
	Stop  int64  `json:"stop"`
}

type ZRankParams 

type ZRankParams struct {
	Key    string `json:"key"`
	Member string `json:"member"`
}

type ZRemParams 

type ZRemParams struct {
	Key     string   `json:"key"`
	Members []string `json:"members"`
}

type ZRevRangeByScoreParams 

type ZRevRangeByScoreParams struct {
	Key string `json:"key"`
	Min string `json:"min"`
	Max string `json:"max"`
}

type ZRevRangeParams 

type ZRevRangeParams struct {
	Key   string `json:"key"`
	Start int64  `json:"start"`
	Stop  int64  `json:"stop"`
}

type ZScoreParams 

type ZScoreParams struct {
	Key    string `json:"key"`
	Member string `json:"member"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.