app

package

v0.7.2 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 38 Imported by: 0

Details

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

Repository

github.com/clyso/chorus

Links

Documentation ¶

Index ¶

Variables
func CreateClient(t testing.TB, storAddr s3.StorageAddress, cred s3.CredentialsV4) (*mclient.Client, *mclient.Core)
func DeepCopyStruct[T any](in T) (out T, err error)
func ProxyS3Config(main string, storages map[string]s3.Storage) proxy.Storages
func WorkerS3Config(main string, storages map[string]s3.Storage) objstore.Config
func WorkerSwiftConfig(main string, storages map[string]swift.Storage) objstore.Config
type Chorus
- func SetupChorus(t testing.TB, workerConf *worker.Config, proxyConf *proxy.Config) Chorus
type EmbeddedEnv
- func SetupEmbedded(t testing.TB, workerConf *worker.Config, proxyConf *proxy.Config) EmbeddedEnv
- func (e *EmbeddedEnv) CreateMainFollowerUserReplications(t testing.TB)

Constants ¶

This section is empty.

Variables ¶

View Source

var WorkerRetryConf = handler.Config{
	SwiftRetryInterval:       asynqRetry * 5,
	PauseRetryInterval:       asynqRetry * 2,
	SwitchRetryInterval:      asynqRetry * 2,
	QueueUpdateInterval:      asynqRetry * 2,
	TaskCheckInterval:        asynqRetry,
	DelayedTaskCheckInterval: asynqRetry * 2,
	CustomErrRetryInterval:   &asynqRetry,
}

Functions ¶

func CreateClient ¶ added in v0.7.0

func CreateClient(t testing.TB, storAddr s3.StorageAddress, cred s3.CredentialsV4) (*mclient.Client, *mclient.Core)

func DeepCopyStruct ¶ added in v0.7.0

func DeepCopyStruct[T any](in T) (out T, err error)

generic parameter function to deepcopy struct using yaml marshal/unmarshal

func ProxyS3Config ¶ added in v0.7.0

func ProxyS3Config(main string, storages map[string]s3.Storage) proxy.Storages

func WorkerS3Config ¶ added in v0.7.0

func WorkerS3Config(main string, storages map[string]s3.Storage) objstore.Config

func WorkerSwiftConfig ¶ added in v0.7.1

func WorkerSwiftConfig(main string, storages map[string]swift.Storage) objstore.Config

Types ¶

type Chorus ¶ added in v0.7.0

type Chorus struct {
	PolicyClient  pb.PolicyClient
	ChorusClient  pb.ChorusClient
	WebhookClient pb.WebhookClient

	UrlHttpApi string
	ProxyAddr  string
	ProxyPort  int

	WaitShort  time.Duration
	RetryShort time.Duration
	WaitLong   time.Duration
	RetryLong  time.Duration
}

func SetupChorus ¶ added in v0.7.0

func SetupChorus(t testing.TB, workerConf *worker.Config, proxyConf *proxy.Config) Chorus

type EmbeddedEnv ¶

type EmbeddedEnv struct {
	MainClient     *mclient.Client
	F1Client       *mclient.Client
	F2Client       *mclient.Client
	ProxyClient    *mclient.Client
	ProxyAwsClient *aws_s3.S3
	MpMainClient   *mclient.Core
	MpF1Client     *mclient.Core
	MpF2Client     *mclient.Core
	MpProxyClient  *mclient.Core

	TaskClient *asynq.Client

	PolicyClient pb.PolicyClient
	ChorusClient pb.ChorusClient
	DiffClient   pb.DiffClient

	UrlHttpApi string

	WaitShort  time.Duration
	RetryShort time.Duration
	WaitLong   time.Duration
	RetryLong  time.Duration
}

func SetupEmbedded ¶

func SetupEmbedded(t testing.TB, workerConf *worker.Config, proxyConf *proxy.Config) EmbeddedEnv

func (*EmbeddedEnv) CreateMainFollowerUserReplications ¶

func (e *EmbeddedEnv) CreateMainFollowerUserReplications(t testing.TB)

Source Files ¶

View all Source files

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