store

package
v0.0.31 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2024 License: MIT Imports: 24 Imported by: 8

Documentation

Index

Constants

View Source 
const (
	MaxStreamLength = 50
)

Variables

This section is empty.

Functions

func NewRedis 

func NewRedis(config RedisConfig) data.Store

func NewWeb added in v0.0.9 

func NewWeb(config WebConfig) data.Store

Types

type Redis 

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

func (*Redis) Connect 

func (s *Redis) Connect(ctx context.Context)

func (*Redis) CreateEntity 

func (s *Redis) CreateEntity(ctx context.Context, entityType, parentId, name string)

func (*Redis) CreateSnapshot 

func (s *Redis) CreateSnapshot(ctx context.Context) data.Snapshot

func (*Redis) DeleteEntity 

func (s *Redis) DeleteEntity(ctx context.Context, entityId string)

func (*Redis) Disconnect 

func (s *Redis) Disconnect(ctx context.Context)

func (*Redis) EntityExists 

func (s *Redis) EntityExists(ctx context.Context, entityId string) bool

func (*Redis) FieldExists 

func (s *Redis) FieldExists(ctx context.Context, fieldName, entityType string) bool

func (*Redis) FindEntities 

func (s *Redis) FindEntities(ctx context.Context, entityType string) []string

func (*Redis) GetEntity 

func (s *Redis) GetEntity(ctx context.Context, entityId string) data.Entity

func (*Redis) GetEntitySchema 

func (s *Redis) GetEntitySchema(ctx context.Context, entityType string) data.EntitySchema

func (*Redis) GetEntityTypes 

func (s *Redis) GetEntityTypes(ctx context.Context) []string

func (*Redis) GetFieldSchema 

func (s *Redis) GetFieldSchema(ctx context.Context, entityType, fieldName string) data.FieldSchema

func (*Redis) IsConnected 

func (s *Redis) IsConnected(ctx context.Context) bool

func (*Redis) Notify 

func (s *Redis) Notify(ctx context.Context, nc data.NotificationConfig, cb data.NotificationCallback) data.NotificationToken

func (*Redis) ProcessNotifications 

func (s *Redis) ProcessNotifications(ctx context.Context)

func (*Redis) Read 

func (s *Redis) Read(ctx context.Context, requests ...data.Request)

func (*Redis) ResolveIndirection 

func (s *Redis) ResolveIndirection(ctx context.Context, indirectField, entityId string) (string, string)

func (*Redis) RestoreSnapshot 

func (s *Redis) RestoreSnapshot(ctx context.Context, ss data.Snapshot)

func (*Redis) SetEntity 

func (s *Redis) SetEntity(ctx context.Context, e data.Entity)

func (*Redis) SetEntitySchema 

func (s *Redis) SetEntitySchema(ctx context.Context, newSchema data.EntitySchema)

func (*Redis) SetFieldSchema 

func (s *Redis) SetFieldSchema(ctx context.Context, entityType, fieldName string, value data.FieldSchema)

func (*Redis) SortedSetAdd 

func (s *Redis) SortedSetAdd(ctx context.Context, key string, member string, score float64) int64

func (*Redis) SortedSetRangeByScoreWithScores 

func (s *Redis) SortedSetRangeByScoreWithScores(ctx context.Context, key string, min, max string) []data.SortedSetMember

func (*Redis) SortedSetRemove 

func (s *Redis) SortedSetRemove(ctx context.Context, key string, member string) int64

func (*Redis) SortedSetRemoveRangeByRank 

func (s *Redis) SortedSetRemoveRangeByRank(ctx context.Context, key string, start, stop int64) int64

func (*Redis) TempDel 

func (s *Redis) TempDel(ctx context.Context, key string)

func (*Redis) TempExpire 

func (s *Redis) TempExpire(ctx context.Context, key string, expiration time.Duration)

func (*Redis) TempGet 

func (s *Redis) TempGet(ctx context.Context, key string) string

func (*Redis) TempSet 

func (s *Redis) TempSet(ctx context.Context, key, value string, expiration time.Duration) bool

func (*Redis) Unnotify 

func (s *Redis) Unnotify(ctx context.Context, e string)

func (*Redis) UnnotifyCallback 

func (s *Redis) UnnotifyCallback(ctx context.Context, e string, c data.NotificationCallback)

func (*Redis) Write 

func (s *Redis) Write(ctx context.Context, requests ...data.Request)

type RedisConfig 

type RedisConfig struct {
	Address  string
	Password string
}

type RedisKeyGenerator 

type RedisKeyGenerator struct{}

schema:entity:<type> -> DatabaseEntitySchema schema:field:<name> -> DatabaseFieldSchema instance:entity:<entityId> -> DatabaseEntity instance:field:<name>:<entityId> -> DatabaseField instance:type:<entityType> -> []string{entityId...} instance:notification-config:<entityId>:<fieldName> -> []string{subscriptionId...} instance:notification-config:<entityType>:<fieldName> -> []string{subscriptionId...}

func (*RedisKeyGenerator) GetEntityIdNotificationConfigKey 

func (g *RedisKeyGenerator) GetEntityIdNotificationConfigKey(entityId, fieldName string) string

func (*RedisKeyGenerator) GetEntityKey 

func (g *RedisKeyGenerator) GetEntityKey(entityId string) string

func (*RedisKeyGenerator) GetEntitySchemaKey 

func (g *RedisKeyGenerator) GetEntitySchemaKey(entityType string) string

func (*RedisKeyGenerator) GetEntityTypeKey 

func (g *RedisKeyGenerator) GetEntityTypeKey(entityType string) string

func (*RedisKeyGenerator) GetEntityTypeNotificationConfigKey 

func (g *RedisKeyGenerator) GetEntityTypeNotificationConfigKey(entityType, fieldName string) string

func (*RedisKeyGenerator) GetFieldKey 

func (g *RedisKeyGenerator) GetFieldKey(fieldName, entityId string) string

func (*RedisKeyGenerator) GetNotificationChannelKey 

func (g *RedisKeyGenerator) GetNotificationChannelKey(serviceId string) string

type Web added in v0.0.9 

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

func (*Web) Connect added in v0.0.9 

func (s *Web) Connect(ctx context.Context)

func (*Web) CreateEntity added in v0.0.9 

func (s *Web) CreateEntity(ctx context.Context, entityType, parentId, name string)

func (*Web) CreateSnapshot added in v0.0.9 

func (s *Web) CreateSnapshot(ctx context.Context) data.Snapshot

func (*Web) DeleteEntity added in v0.0.9 

func (s *Web) DeleteEntity(ctx context.Context, entityId string)

func (*Web) Disconnect added in v0.0.9 

func (s *Web) Disconnect(ctx context.Context)

func (*Web) EntityExists added in v0.0.9 

func (s *Web) EntityExists(ctx context.Context, entityId string) bool

func (*Web) FieldExists added in v0.0.9 

func (s *Web) FieldExists(ctx context.Context, fieldName, entityType string) bool

func (*Web) FindEntities added in v0.0.9 

func (s *Web) FindEntities(ctx context.Context, entityType string) []string

func (*Web) GetEntity added in v0.0.9 

func (s *Web) GetEntity(ctx context.Context, entityId string) data.Entity

func (*Web) GetEntitySchema added in v0.0.9 

func (s *Web) GetEntitySchema(ctx context.Context, entityType string) data.EntitySchema

func (*Web) GetEntityTypes added in v0.0.9 

func (s *Web) GetEntityTypes(ctx context.Context) []string

func (*Web) IsConnected added in v0.0.9 

func (s *Web) IsConnected(ctx context.Context) bool

func (*Web) Notify added in v0.0.9 

func (s *Web) Notify(ctx context.Context, config data.NotificationConfig, cb data.NotificationCallback) data.NotificationToken

func (*Web) ProcessNotifications added in v0.0.9 

func (s *Web) ProcessNotifications(ctx context.Context)

func (*Web) Read added in v0.0.9 

func (s *Web) Read(ctx context.Context, requests ...data.Request)

func (*Web) RestoreSnapshot added in v0.0.9 

func (s *Web) RestoreSnapshot(ctx context.Context, ss data.Snapshot)

func (*Web) SetEntity added in v0.0.9 

func (s *Web) SetEntity(ctx context.Context, e data.Entity)

func (*Web) SetEntitySchema added in v0.0.9 

func (s *Web) SetEntitySchema(ctx context.Context, schema data.EntitySchema)

func (*Web) SortedSetAdd added in v0.0.9 

func (s *Web) SortedSetAdd(ctx context.Context, key string, member string, score float64) int64

func (*Web) SortedSetRangeByScoreWithScores added in v0.0.9 

func (s *Web) SortedSetRangeByScoreWithScores(ctx context.Context, key string, min, max string) []data.SortedSetMember

func (*Web) SortedSetRemove added in v0.0.9 

func (s *Web) SortedSetRemove(ctx context.Context, key string, member string) int64

func (*Web) SortedSetRemoveRangeByRank added in v0.0.9 

func (s *Web) SortedSetRemoveRangeByRank(ctx context.Context, key string, start, stop int64) int64

func (*Web) TempDel added in v0.0.9 

func (s *Web) TempDel(ctx context.Context, key string)

func (*Web) TempExpire added in v0.0.9 

func (s *Web) TempExpire(ctx context.Context, key string, expiration time.Duration)

func (*Web) TempGet added in v0.0.9 

func (s *Web) TempGet(ctx context.Context, key string) string

func (*Web) TempSet added in v0.0.9 

func (s *Web) TempSet(ctx context.Context, key, value string, expiration time.Duration) bool

Implement remaining data.Store interface methods for temp storage and sorted sets

func (*Web) Unnotify added in v0.0.9 

func (s *Web) Unnotify(ctx context.Context, token string)

func (*Web) UnnotifyCallback added in v0.0.9 

func (s *Web) UnnotifyCallback(ctx context.Context, token string, cb data.NotificationCallback)

func (*Web) Write added in v0.0.9 

func (s *Web) Write(ctx context.Context, requests ...data.Request)

type WebConfig added in v0.0.9 

type WebConfig struct {
	Address string
}

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.