redisstate

Documentation

Index

• func CastRedisPropertiesToStateEntry(id string, properties map[string]string) (states.StateEntry, error)
• type RedisStateProvider
  • func (r *RedisStateProvider) Delete(ctx context.Context, request states.DeleteRequest) error
  • func (r *RedisStateProvider) Get(ctx context.Context, request states.GetRequest) (states.StateEntry, error)
  • func (r *RedisStateProvider) ID() string
  • func (r *RedisStateProvider) Init(config providers.IProviderConfig) error
  • func (i *RedisStateProvider) InitWithMap(properties map[string]string) error
  • func (r *RedisStateProvider) List(ctx context.Context, request states.ListRequest) ([]states.StateEntry, string, error)
  • func (r *RedisStateProvider) SetContext(ctx *contexts.ManagerContext)
  • func (r *RedisStateProvider) Upsert(ctx context.Context, entry states.UpsertRequest) (string, error)
• type RedisStateProviderConfig
  • func RedisStateProviderConfigFromMap(properties map[string]string) (RedisStateProviderConfig, error)

Functions

func CastRedisPropertiesToStateEntry

func CastRedisPropertiesToStateEntry(id string, properties map[string]string) (states.StateEntry, error)

Types

type RedisStateProvider

type RedisStateProvider struct {
	Config  RedisStateProviderConfig
	Context *contexts.ManagerContext
	Client  *redis.Client
	Ctx     context.Context
	Cancel  context.CancelFunc
}

func (*RedisStateProvider) Delete

func (r *RedisStateProvider) Delete(ctx context.Context, request states.DeleteRequest) error

func (*RedisStateProvider) Get

func (r *RedisStateProvider) Get(ctx context.Context, request states.GetRequest) (states.StateEntry, error)

func (*RedisStateProvider) ID

func (r *RedisStateProvider) ID() string

func (*RedisStateProvider) Init

func (r *RedisStateProvider) Init(config providers.IProviderConfig) error

func (*RedisStateProvider) InitWithMap

func (i *RedisStateProvider) InitWithMap(properties map[string]string) error

func (*RedisStateProvider) List

func (r *RedisStateProvider) List(ctx context.Context, request states.ListRequest) ([]states.StateEntry, string, error)

func (*RedisStateProvider) SetContext

func (r *RedisStateProvider) SetContext(ctx *contexts.ManagerContext)

func (*RedisStateProvider) Upsert

func (r *RedisStateProvider) Upsert(ctx context.Context, entry states.UpsertRequest) (string, error)

type RedisStateProviderConfig

type RedisStateProviderConfig struct {
	Name        string `json:"name"`
	Host        string `json:"host"`
	Password    string `json:"password,omitempty"`
	RequiresTLS bool   `json:"requiresTLS,omitempty"`
}

func RedisStateProviderConfigFromMap

func RedisStateProviderConfigFromMap(properties map[string]string) (RedisStateProviderConfig, error)