repositories

Documentation

Index

• Constants
• type FloatSignalArgs
• type Repository
  • func NewRepository(logger *zerolog.Logger, settings config.Settings) (*Repository, error)
  • func (r *Repository) GetLatestSignalFloat(ctx context.Context, sigArgs SignalArgs) (*model.SignalFloat, error)
  • func (r *Repository) GetLatestSignalString(ctx context.Context, sigArgs SignalArgs) (*model.SignalString, error)
  • func (r *Repository) GetSignalFloats(ctx context.Context, sigArgs FloatSignalArgs) ([]*model.SignalFloat, error)
  • func (r *Repository) GetSignalString(ctx context.Context, sigArgs StringSignalArgs) ([]*model.SignalString, error)
• type SignalArgs
• type StringSignalArgs

Constants

const (
	// MaxPageSize is the maximum page size for paginated results
	MaxPageSize = 100
)

Types

type FloatSignalArgs

type FloatSignalArgs struct {
	Agg model.FloatAggregation
	SignalArgs
}

FloatSignalArgs is the arguments for querying a float signals.

type Repository

type Repository struct {
	Log *zerolog.Logger
	// contains filtered or unexported fields
}

Repository is the base repository for all repositories.

func NewRepository

func NewRepository(logger *zerolog.Logger, settings config.Settings) (*Repository, error)

NewRepository creates a new base repository.

func (*Repository) GetLatestSignalFloat

func (r *Repository) GetLatestSignalFloat(ctx context.Context, sigArgs SignalArgs) (*model.SignalFloat, error)

GetLatestSignalFloat returns the latest float signal based on the provided arguments.

func (*Repository) GetLatestSignalString

func (r *Repository) GetLatestSignalString(ctx context.Context, sigArgs SignalArgs) (*model.SignalString, error)

GetLatestSignalString returns the latest string signal based on the provided arguments.

func (*Repository) GetSignalFloats

func (r *Repository) GetSignalFloats(ctx context.Context, sigArgs FloatSignalArgs) ([]*model.SignalFloat, error)

GetSignalFloats returns the float signals based on the provided arguments.

func (*Repository) GetSignalString

func (r *Repository) GetSignalString(ctx context.Context, sigArgs StringSignalArgs) ([]*model.SignalString, error)

GetSignalString returns the string signals based on the provided arguments.

type SignalArgs

type SignalArgs struct {
	FromTS  time.Time
	ToTS    time.Time
	Name    string
	TokenID uint32
}

SignalArgs is the base arguments for querying signals.

type StringSignalArgs

type StringSignalArgs struct {
	Agg model.StringAggregation
	SignalArgs
}

StringSignalArgs is the arguments for querying a string signals.