storage

Documentation

Index

• type DefaultModCache
  • func NewDefaultModCache() *DefaultModCache
  • func (c *DefaultModCache) Delete(id uuid.UUID) error
  • func (c *DefaultModCache) Get(id uuid.UUID) (wazero.CompilationCache, bool)
  • func (c *DefaultModCache) Put(id uuid.UUID, mod wazero.CompilationCache)
• type MemoryStore
  • func NewMemoryStore() *MemoryStore
  • func (s *MemoryStore) CreateDeploy(deploy *types.Deploy) error
  • func (s *MemoryStore) CreateEndpoint(e *types.Endpoint) error
  • func (s *MemoryStore) GetDeploy(id uuid.UUID) (*types.Deploy, error)
  • func (s *MemoryStore) GetEndpoint(id uuid.UUID) (*types.Endpoint, error)
  • func (s *MemoryStore) UpdateEndpoint(id uuid.UUID, params UpdateEndpointParams) error
• type MetricStore
• type ModCacher
• type RedisStore
  • func NewRedisStore() (*RedisStore, error)
  • func (s *RedisStore) CreateDeploy(deploy *types.Deploy) error
  • func (s *RedisStore) CreateEndpoint(endpoint *types.Endpoint) error
  • func (s *RedisStore) CreateRuntimeMetric(metric *types.RuntimeMetric) error
  • func (s *RedisStore) GetDeploy(id uuid.UUID) (*types.Deploy, error)
  • func (s *RedisStore) GetEndpoint(id uuid.UUID) (*types.Endpoint, error)
  • func (s *RedisStore) GetEndpoints() ([]types.Endpoint, error)
  • func (s *RedisStore) GetRuntimeMetrics(id uuid.UUID) ([]types.RuntimeMetric, error)
  • func (s *RedisStore) UpdateEndpoint(id uuid.UUID, params UpdateEndpointParams) error
• type Store
• type UpdateEndpointParams

Types

type DefaultModCache

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

func NewDefaultModCache

func NewDefaultModCache() *DefaultModCache

func (*DefaultModCache) Delete

func (c *DefaultModCache) Delete(id uuid.UUID) error

func (*DefaultModCache) Get

func (c *DefaultModCache) Get(id uuid.UUID) (wazero.CompilationCache, bool)

func (*DefaultModCache) Put

func (c *DefaultModCache) Put(id uuid.UUID, mod wazero.CompilationCache)

type MemoryStore

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

func NewMemoryStore

func NewMemoryStore() *MemoryStore

func (*MemoryStore) CreateDeploy

func (s *MemoryStore) CreateDeploy(deploy *types.Deploy) error

func (*MemoryStore) CreateEndpoint

func (s *MemoryStore) CreateEndpoint(e *types.Endpoint) error

func (*MemoryStore) GetDeploy

func (s *MemoryStore) GetDeploy(id uuid.UUID) (*types.Deploy, error)

func (*MemoryStore) GetEndpoint

func (s *MemoryStore) GetEndpoint(id uuid.UUID) (*types.Endpoint, error)

func (*MemoryStore) UpdateEndpoint

func (s *MemoryStore) UpdateEndpoint(id uuid.UUID, params UpdateEndpointParams) error

type MetricStore

type MetricStore interface {
	CreateRuntimeMetric(*types.RuntimeMetric) error
	GetRuntimeMetrics(uuid.UUID) ([]types.RuntimeMetric, error)
}

type ModCacher

type ModCacher interface {
	Put(uuid.UUID, wazero.CompilationCache)
	Get(uuid.UUID) (wazero.CompilationCache, bool)
	Delete(uuid.UUID) error
}

type RedisStore

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

RedisStore is the Redis implementation of a Storage interface.

func NewRedisStore

func NewRedisStore() (*RedisStore, error)

NewRedisStore returns a new RedisStore.

This will return an error if we failed to ping the Redis server.

func (*RedisStore) CreateDeploy

func (s *RedisStore) CreateDeploy(deploy *types.Deploy) error

func (*RedisStore) CreateEndpoint

func (s *RedisStore) CreateEndpoint(endpoint *types.Endpoint) error

func (*RedisStore) CreateRuntimeMetric

func (s *RedisStore) CreateRuntimeMetric(metric *types.RuntimeMetric) error

func (*RedisStore) GetDeploy

func (s *RedisStore) GetDeploy(id uuid.UUID) (*types.Deploy, error)

func (*RedisStore) GetEndpoint

func (s *RedisStore) GetEndpoint(id uuid.UUID) (*types.Endpoint, error)

func (*RedisStore) GetEndpoints

func (s *RedisStore) GetEndpoints() ([]types.Endpoint, error)

func (*RedisStore) GetRuntimeMetrics

func (s *RedisStore) GetRuntimeMetrics(id uuid.UUID) ([]types.RuntimeMetric, error)

func (*RedisStore) UpdateEndpoint

func (s *RedisStore) UpdateEndpoint(id uuid.UUID, params UpdateEndpointParams) error

type Store

type Store interface {
	CreateEndpoint(*types.Endpoint) error
	UpdateEndpoint(uuid.UUID, UpdateEndpointParams) error
	GetEndpoint(uuid.UUID) (*types.Endpoint, error)
	GetEndpoints() ([]types.Endpoint, error)
	CreateDeploy(*types.Deploy) error
	GetDeploy(uuid.UUID) (*types.Deploy, error)
}

type UpdateEndpointParams

type UpdateEndpointParams struct {
	Environment    map[string]string
	ActiveDeployID uuid.UUID
	Deploys        []*types.Deploy
}