Documentation
¶
Index ¶
- Constants
- func CleanupEnv(t *testing.T, workerService Service, backtestService Service, ...)
- func LokiContainerAndLogging(t *testing.T, NetworkID string) (ConnectionString string)
- func MinioContainer(t *testing.T, NetworkID string) (ConnectionString, AccessKey, SecretKey string)
- func NATSContainer(t *testing.T, NetworkID string) (ConnectionString string)
- func PostgresContainer(t *testing.T, NetworkID string) (ConnectionString string)
- func Request(t *testing.T, method string, endpoint string, payload interface{}) *http.Response
- func SetUpEnv(t *testing.T, backtest Backtest, strategy *Strategy) error
- func SetupEnvironment(t *testing.T, containers *Containers)
- func SocketReplier(t *testing.T, socket mangos.Socket, ...)
- func SocketRequest(t *testing.T, socket mangos.Socket, task string, request proto.Message, ...)
- func WaitTillContainersAreRemoved(t *testing.T, NetworkID string, timeout time.Duration)
- func WaitUntilCondition(t *testing.T, condition func() (bool, error), timeout time.Duration) error
- type Backtest
- type Containers
- type LokiLogger
- type Service
- type ServiceInstance
- type Strategy
Constants ¶
View Source
const ( PostgresImage = "postgres:alpine" NatsImage = "nats:alpine" MinioImage = "minio/minio:latest" )
Variables ¶
This section is empty.
Functions ¶
func CleanupEnv ¶
func LokiContainerAndLogging ¶
func MinioContainer ¶
func PostgresContainer ¶
func SetupEnvironment ¶
func SetupEnvironment(t *testing.T, containers *Containers)
func SocketReplier ¶
func SocketRequest ¶
Types ¶
type Backtest ¶
type Backtest struct { Name string `json:"name"` Status string `json:"status"` Service string `json:"service"` Calendar string `json:"calendar"` Start time.Time `json:"start"` End time.Time `json:"end"` Benchmark string `json:"benchmark"` Symbols []string `json:"symbols"` IngestedAt *time.Time `json:"ingested_at"` }
type LokiLogger ¶
type LokiLogger struct { LokiURL string // contains filtered or unexported fields }
func (*LokiLogger) Publish ¶
func (l *LokiLogger) Publish(t *testing.T)
type ServiceInstance ¶
func NewServiceInstance ¶
func NewServiceInstance(t *testing.T) *ServiceInstance
func (*ServiceInstance) Close ¶
func (s *ServiceInstance) Close() error
Click to show internal directories.
Click to hide internal directories.