storage

Documentation

Index

• type Endpoint
• type Storage
  • func GetMongoClient(cfg *config.Config) Storage
• type Store
  • func (s *Store) Close(ctx context.Context)
  • func (s *Store) GetEndpoints(ctx context.Context, filter primitive.M) ([]*Endpoint, error)
  • func (s *Store) GetLastEndpoint(ctx context.Context, filter primitive.M) (*Endpoint, error)
  • func (s *Store) GetNames(ctx context.Context) ([]string, error)
  • func (s *Store) SaveEndpoint(ctx context.Context, endpoint *Endpoint) error

Types

type Endpoint

type Endpoint struct {
	ID     primitive.ObjectID `json:"id" bson:"_id,omitempty"`
	Name   string             `json:"name" bson:"name"`
	URL    string             `json:"url" bson:"url"`
	Status bool               `json:"status" bson:"status"`
	Date   int64              `json:"date" bson:"date"`
}

type Storage

type Storage interface {
	GetLastEndpoint(context.Context, primitive.M) (*Endpoint, error)
	GetEndpoints(context.Context, primitive.M) ([]*Endpoint, error)
	SaveEndpoint(context.Context, *Endpoint) error
	GetNames(context.Context) ([]string, error)
	Close(context.Context)
}

func GetMongoClient

func GetMongoClient(cfg *config.Config) Storage

type Store

type Store struct {
	Client *mongo.Client
	DBName string
}

func (*Store) Close

func (s *Store) Close(ctx context.Context)

func (*Store) GetEndpoints

func (s *Store) GetEndpoints(ctx context.Context, filter primitive.M) ([]*Endpoint, error)

func (*Store) GetLastEndpoint

func (s *Store) GetLastEndpoint(ctx context.Context, filter primitive.M) (*Endpoint, error)

func (*Store) GetNames

func (s *Store) GetNames(ctx context.Context) ([]string, error)

func (*Store) SaveEndpoint

func (s *Store) SaveEndpoint(ctx context.Context, endpoint *Endpoint) error