adapter

package

v1.0.0-beta.217 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

Index ¶

func New(config Config) (progressmanager.Adapter, error)
func NewNoop() progressmanager.Adapter
type Config
- func (c Config) Validate() error
type MockProgressManager
- func NewMockProgressManager() *MockProgressManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(config Config) (progressmanager.Adapter, error)

func NewNoop ¶

func NewNoop() progressmanager.Adapter

NewNoop creates a no-operation adapter that implements the progressmanager.Adapter interface but performs no actual operations. This is useful for testing or when progress tracking is disabled.

Types ¶

type Config ¶

type Config struct {
	Expiration time.Duration
	Redis      *redis.Client
	Logger     *slog.Logger
}

func (Config) Validate ¶

func (c Config) Validate() error

type MockProgressManager ¶

type MockProgressManager struct {
	mock.Mock
}

MockProgressManager is a mock for the ProgressManager

func NewMockProgressManager ¶

func NewMockProgressManager() *MockProgressManager

func (*MockProgressManager) DeleteProgressByRuntimeID ¶

func (m *MockProgressManager) DeleteProgressByRuntimeID(ctx context.Context, runtimeID string) error

func (*MockProgressManager) GetProgress ¶

func (m *MockProgressManager) GetProgress(ctx context.Context, input progressmanagerentity.GetProgressInput) (*progressmanagerentity.Progress, error)

func (*MockProgressManager) UpsertProgress ¶

func (m *MockProgressManager) UpsertProgress(ctx context.Context, input progressmanagerentity.UpsertProgressInput) error

Source Files ¶

View all Source files

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