nodeclient

Documentation

Index

• type Client
  • func (c *Client) ProbeSources(ctx context.Context, opts SourceProbeOptions) error
  • func (c *Client) Run(ctx context.Context) error
  • func (c *Client) RunOnce(ctx context.Context) error
• type S3SnapshotUploader
  • func (S3SnapshotUploader) UploadSnapshot(ctx context.Context, role nodeconfig.NodeRoleConfig, localPath string, ...) (string, error)
• type SnapshotUploader
• type SourceProbeOptions

Types

type Client

type Client struct {
	Config           nodeconfig.Config
	Logger           *slog.Logger
	SnapshotUploader SnapshotUploader
	MediaMetrics     *sapientmedia.Metrics
}

func (*Client) ProbeSources

func (c *Client) ProbeSources(ctx context.Context, opts SourceProbeOptions) error

func (*Client) Run

func (c *Client) Run(ctx context.Context) error

func (*Client) RunOnce

func (c *Client) RunOnce(ctx context.Context) error

type S3SnapshotUploader

type S3SnapshotUploader struct{}

func (S3SnapshotUploader) UploadSnapshot

func (S3SnapshotUploader) UploadSnapshot(ctx context.Context, role nodeconfig.NodeRoleConfig, localPath string, taskID string, contentType string, now time.Time) (string, error)

type SnapshotUploader

type SnapshotUploader interface {
	UploadSnapshot(ctx context.Context, role nodeconfig.NodeRoleConfig, localPath string, taskID string, contentType string, now time.Time) (string, error)
}

type SourceProbeOptions

type SourceProbeOptions struct {
	Force             bool
	FailOnUnavailable bool
}