storage

Documentation

Index

• type Handler
  • func Init(cfg config.StorageConfig) (*Handler, error)
  • func (h *Handler) Create(ctx context.Context, p proxy.Proxy) (*Proxy, bool, error)
  • func (h *Handler) GetProxies(ctx context.Context, opts *QueryOptions) ([]*Proxy, error)
  • func (h *Handler) GetProxiesCount(ctx context.Context) (int64, error)
  • func (h *Handler) Remove(ctx context.Context, id uint) error
  • func (h *Handler) Update(ctx context.Context, id uint, m map[string]any) error
• type Proxy
  • func NewProxy(p proxy.Proxy) (*Proxy, error)
• type QueryOptions
• type Result

Types

type Handler

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

func Init

func Init(cfg config.StorageConfig) (*Handler, error)

func (*Handler) Create

func (h *Handler) Create(ctx context.Context, p proxy.Proxy) (*Proxy, bool, error)

func (*Handler) GetProxies

func (h *Handler) GetProxies(ctx context.Context, opts *QueryOptions) ([]*Proxy, error)

func (*Handler) GetProxiesCount

func (h *Handler) GetProxiesCount(ctx context.Context) (int64, error)

func (*Handler) Remove

func (h *Handler) Remove(ctx context.Context, id uint) error

func (*Handler) Update

func (h *Handler) Update(ctx context.Context, id uint, m map[string]any) error

type Proxy

type Proxy struct {
	ID        uint `gorm:"primarykey"`
	CreatedAt time.Time
	UpdatedAt time.Time
	*proxy.Base
	Config string
}

func NewProxy

func NewProxy(p proxy.Proxy) (*Proxy, error)

type QueryOptions

type QueryOptions struct {
	ID               uint
	EmptyCountryCode bool
	CountryCodes     string
	NotCountryCodes  string
	Count            int
	Fast             bool
}

type Result

type Result struct {
	Proxy *Proxy
	Error error
}