memory

package

v1.20.3 Latest Latest Go to latest Published: Oct 25, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/whywaita/myshoes

Links

Open Source Insights

Documentation ¶

Index ¶

type Memory
- func New() (*Memory, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Memory ¶

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

Memory is implement datastore on-memory

func New ¶

func New() (*Memory, error)

New create map

func (*Memory) CreateRunner ¶

func (m *Memory) CreateRunner(ctx context.Context, runner datastore.Runner) error

CreateRunner add a runner

func (*Memory) CreateTarget ¶

func (m *Memory) CreateTarget(ctx context.Context, target datastore.Target) error

CreateTarget create a target

func (*Memory) DeleteJob ¶

func (m *Memory) DeleteJob(ctx context.Context, id uuid.UUID) error

DeleteJob delete a job

func (*Memory) DeleteRunner ¶

func (m *Memory) DeleteRunner(ctx context.Context, id uuid.UUID, deletedAt time.Time, reason datastore.RunnerStatus) error

DeleteRunner delete a runner

func (*Memory) DeleteTarget ¶

func (m *Memory) DeleteTarget(ctx context.Context, id uuid.UUID) error

DeleteTarget delete a target

func (*Memory) EnqueueJob ¶

func (m *Memory) EnqueueJob(ctx context.Context, job datastore.Job) error

EnqueueJob add a job

func (*Memory) GetLock ¶ added in v1.8.1

func (m *Memory) GetLock(ctx context.Context) error

GetLock get lock

func (*Memory) GetRunner ¶

func (m *Memory) GetRunner(ctx context.Context, id uuid.UUID) (*datastore.Runner, error)

GetRunner get a runner

func (*Memory) GetTarget ¶

func (m *Memory) GetTarget(ctx context.Context, id uuid.UUID) (*datastore.Target, error)

GetTarget get a target

func (*Memory) GetTargetByScope ¶

func (m *Memory) GetTargetByScope(ctx context.Context, scope string) (*datastore.Target, error)

GetTargetByScope get a target from scope

func (*Memory) IsLocked ¶ added in v1.8.1

func (m *Memory) IsLocked(ctx context.Context) (string, error)

IsLocked return status of lock

func (*Memory) ListJobs ¶

func (m *Memory) ListJobs(ctx context.Context) ([]datastore.Job, error)

ListJobs get all jobs

func (*Memory) ListRunners ¶

func (m *Memory) ListRunners(ctx context.Context) ([]datastore.Runner, error)

ListRunners get a all runners

func (*Memory) ListRunnersByTargetID ¶ added in v1.10.1

func (m *Memory) ListRunnersByTargetID(ctx context.Context, targetID uuid.UUID) ([]datastore.Runner, error)

ListRunnersByTargetID get a not deleted runners that has target_id

func (*Memory) ListRunnersLogBySince ¶ added in v1.18.0

func (m *Memory) ListRunnersLogBySince(ctx context.Context, since time.Time) ([]datastore.Runner, error)

ListRunnersLogBySince ListRunnerLog get a runners since time

func (*Memory) ListTargets ¶

func (m *Memory) ListTargets(ctx context.Context) ([]datastore.Target, error)

ListTargets get a all targets

func (*Memory) UpdateTargetParam ¶ added in v1.10.0

func (m *Memory) UpdateTargetParam(ctx context.Context, targetID uuid.UUID, newResourceType datastore.ResourceType, newProviderURL string) error

UpdateTargetParam update parameter of target

func (*Memory) UpdateTargetStatus ¶ added in v1.3.0

func (m *Memory) UpdateTargetStatus(ctx context.Context, targetID uuid.UUID, newStatus datastore.TargetStatus, description string) error

UpdateTargetStatus update status in target

func (*Memory) UpdateToken ¶ added in v1.7.0

func (m *Memory) UpdateToken(ctx context.Context, targetID uuid.UUID, newToken string, newExpiredAt time.Time) error

UpdateToken update token in target

Source Files ¶

View all Source files

memory.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL