storage

Documentation

Index

• Variables
• func NewIterator(c *bolt.Cursor, reverse bool) *iterator
• func NewStormStorage(lc fx.Lifecycle, conf *cmd.Conf, log *zerolog.Logger) (interactor.StorageProvider, error)
• type StormStorage
  • func (s StormStorage) CountTimedResponses(svc *models.Service) (int, error)
  • func (s StormStorage) GetAllServices() ([]*models.Service, error)
  • func (s StormStorage) GetServiceByID(id string) (*models.Service, error)
  • func (s StormStorage) GetServices(user *models.User) ([]*models.Service, error)
  • func (s StormStorage) GetTimedResponseRange(svc *models.Service, from, to time.Time) ([]*models.TimedResponse, error)
  • func (s StormStorage) GetTimedResponses(svc *models.Service, limit int, reverse bool) ([]*models.TimedResponse, error)
  • func (s StormStorage) GetUserByEmail(email string) (*models.User, error)
  • func (s StormStorage) GetUserByID(id string) (*models.User, error)
  • func (s StormStorage) SaveRawService(svc *models.Service) error
  • func (s StormStorage) SaveService(user *models.User, svc *models.Service) error
  • func (s StormStorage) SaveTimedResponse(tr *models.TimedResponse) error
  • func (s StormStorage) SaveUser(usr *models.User) error
  • func (st StormStorage) SyncCount()
• type TimedResponse
  • func (*TimedResponse) Descriptor() ([]byte, []int)
  • func (x *TimedResponse) GetServer() *durationpb.Duration
  • func (x *TimedResponse) GetStatus() int32
  • func (x *TimedResponse) GetTotal() *durationpb.Duration
  • func (*TimedResponse) ProtoMessage()
  • func (x *TimedResponse) ProtoReflect() protoreflect.Message
  • func (x *TimedResponse) Reset()
  • func (x *TimedResponse) String() string

Variables

var File_implem_storage_storm_timed_response_proto protoreflect.FileDescriptor

Functions

func NewIterator

func NewIterator(c *bolt.Cursor, reverse bool) *iterator

func NewStormStorage

func NewStormStorage(lc fx.Lifecycle, conf *cmd.Conf, log *zerolog.Logger) (interactor.StorageProvider, error)

Types

type StormStorage

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

func (StormStorage) CountTimedResponses

func (s StormStorage) CountTimedResponses(svc *models.Service) (int, error)

func (StormStorage) GetAllServices

func (s StormStorage) GetAllServices() ([]*models.Service, error)

func (StormStorage) GetServiceByID

func (s StormStorage) GetServiceByID(id string) (*models.Service, error)

func (StormStorage) GetServices

func (s StormStorage) GetServices(user *models.User) ([]*models.Service, error)

func (StormStorage) GetTimedResponseRange

func (s StormStorage) GetTimedResponseRange(svc *models.Service, from, to time.Time) ([]*models.TimedResponse, error)

func (StormStorage) GetTimedResponses

func (s StormStorage) GetTimedResponses(svc *models.Service, limit int, reverse bool) ([]*models.TimedResponse, error)

func (StormStorage) GetUserByEmail

func (s StormStorage) GetUserByEmail(email string) (*models.User, error)

func (StormStorage) GetUserByID

func (s StormStorage) GetUserByID(id string) (*models.User, error)

func (StormStorage) SaveRawService

func (s StormStorage) SaveRawService(svc *models.Service) error

func (StormStorage) SaveService

func (s StormStorage) SaveService(user *models.User, svc *models.Service) error

func (StormStorage) SaveTimedResponse

func (s StormStorage) SaveTimedResponse(tr *models.TimedResponse) error

func (StormStorage) SaveUser

func (s StormStorage) SaveUser(usr *models.User) error

func (StormStorage) SyncCount

func (st StormStorage) SyncCount()

type TimedResponse

type TimedResponse struct {
	Status int32                `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Server *durationpb.Duration `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	Total  *durationpb.Duration `protobuf:"bytes,3,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*TimedResponse) Descriptor

func (*TimedResponse) Descriptor() ([]byte, []int)

Deprecated: Use TimedResponse.ProtoReflect.Descriptor instead.

func (*TimedResponse) GetServer

func (x *TimedResponse) GetServer() *durationpb.Duration

func (*TimedResponse) GetStatus

func (x *TimedResponse) GetStatus() int32

func (*TimedResponse) GetTotal

func (x *TimedResponse) GetTotal() *durationpb.Duration

func (*TimedResponse) ProtoMessage

func (*TimedResponse) ProtoMessage()

func (*TimedResponse) ProtoReflect

func (x *TimedResponse) ProtoReflect() protoreflect.Message

func (*TimedResponse) Reset

func (x *TimedResponse) Reset()

func (*TimedResponse) String

func (x *TimedResponse) String() string