repositories

Documentation

Index

• type CHService
• type Repository
  • func NewRepository(logger *zerolog.Logger, chService CHService) *Repository
  • func (r *Repository) GetSignal(ctx context.Context, aggArgs *model.AggregatedSignalArgs) ([]*model.SignalAggregations, error)
  • func (r *Repository) GetSignalLatest(ctx context.Context, latestArgs *model.LatestSignalsArgs) (*model.SignalCollection, error)
• type ValidationError
  • func (v ValidationError) Error() string

Types

type CHService

type CHService interface {
	GetAggregatedSignals(ctx context.Context, aggArgs *model.AggregatedSignalArgs) ([]*model.AggSignal, error)
	GetLatestSignals(ctx context.Context, latestArgs *model.LatestSignalsArgs) ([]*vss.Signal, error)
}

CHService is the interface for the ClickHouse service.

type Repository

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

Repository is the base repository for all repositories.

func NewRepository

func NewRepository(logger *zerolog.Logger, chService CHService) *Repository

NewRepository creates a new base repository. clientCAs is optional and can be nil.

func (*Repository) GetSignal

func (r *Repository) GetSignal(ctx context.Context, aggArgs *model.AggregatedSignalArgs) ([]*model.SignalAggregations, error)

GetSignal returns the aggregated signals for the given tokenID, interval, from, to and filter.

func (*Repository) GetSignalLatest

func (r *Repository) GetSignalLatest(ctx context.Context, latestArgs *model.LatestSignalsArgs) (*model.SignalCollection, error)

GetSignalLatest returns the latest signals for the given tokenID and filter.

type ValidationError

type ValidationError string

ValidationError is an error type for validation errors.

func (ValidationError) Error

func (v ValidationError) Error() string