manticore

Documentation

Index

• type Client
  • func New(tbl string) (*Client, error)
  • func (c *Client) Bulk(ctx context.Context, entries *[]feed.Entry) error
  • func (c *Client) CalculateLimitCount(duration time.Duration) int
  • func (c *Client) Delete(ctx context.Context, id *int64) error
  • func (c *Client) FindAll(ctx context.Context, limit int) (chan feed.Entry, error)
  • func (c *Client) FindAllByUrl(ctx context.Context, url string) ([]feed.Entry, error)
  • func (c *Client) FindByUrl(ctx context.Context, url string) (*feed.Entry, error)
  • func (c *Client) FindDuration(ctx context.Context, duration time.Duration) (chan string, error)
  • func (c *Client) Insert(ctx context.Context, entry *feed.Entry) (*int64, error)
  • func (c *Client) Update(ctx context.Context, entry *feed.Entry) error
• type DBEntry
  • func NewDBEntry(entry *feed.Entry) *DBEntry
• type IndexStatus
• type Response

Types

type Client

type Client struct {
	Index string
	// contains filtered or unexported fields
}

func New

func New(tbl string) (*Client, error)

func (*Client) Bulk

func (c *Client) Bulk(ctx context.Context, entries *[]feed.Entry) error

func (*Client) CalculateLimitCount

func (c *Client) CalculateLimitCount(duration time.Duration) int

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, id *int64) error

func (*Client) FindAll

func (c *Client) FindAll(ctx context.Context, limit int) (chan feed.Entry, error)

func (*Client) FindAllByUrl

func (c *Client) FindAllByUrl(ctx context.Context, url string) ([]feed.Entry, error)

func (*Client) FindByUrl

func (c *Client) FindByUrl(ctx context.Context, url string) (*feed.Entry, error)

func (*Client) FindDuration

func (c *Client) FindDuration(ctx context.Context, duration time.Duration) (chan string, error)

func (*Client) Insert

func (c *Client) Insert(ctx context.Context, entry *feed.Entry) (*int64, error)

func (*Client) Update

func (c *Client) Update(ctx context.Context, entry *feed.Entry) error

type DBEntry

type DBEntry struct {
	Language   string `json:"language"`
	Title      string `json:"title"`
	Url        string `json:"url"`
	Updated    int64  `json:"updated"`
	Published  int64  `json:"published"`
	Summary    string `json:"summary"`
	Content    string `json:"content"`
	Author     string `json:"author"`
	Number     string `json:"number"`
	ResourceID int    `json:"resource_id"`
	Created    int64  `json:"created"`
	Chunk      int    `json:"chunk"`
	UpdatedAt  int64  `json:"updated_at"`
}

func NewDBEntry

func NewDBEntry(entry *feed.Entry) *DBEntry

NewDBEntry только для создания новой записи insert, в этой записи присваивается поле created, далее это поле никогда не изменяется при редактировании записи.

type IndexStatus

type IndexStatus struct {
	Columns []map[string]map[string]string `json:"columns"`
	Data    []map[string]string            `json:"data"`
	Total   int                            `json:"total"`
	Error   string                         `json:"error"`
	Warning string                         `json:"warning"`
}

type Response

type Response struct {
	Took     int  `json:"took"`
	TimedOut bool `json:"timed_out"`
	Hits     struct {
		Total         int    `json:"total"`
		TotalRelation string `json:"total_relation"`
		Hits          []struct {
			Id     int64 `json:"_id"`
			Score  int   `json:"_score"`
			Source struct {
				Title      string `json:"title"`
				Summary    string `json:"summary"`
				Content    string `json:"content"`
				ResourceID int    `json:"resource_id"`
				Chunk      int    `json:"chunk"`
				Published  int64  `json:"published"`
				Updated    int64  `json:"updated"`
				Created    int64  `json:"created"`
				UpdatedAt  int64  `json:"updated_at"`
				Language   string `json:"language"`
				Url        string `json:"url"`
				Author     string `json:"author"`
				Number     string `json:"number"`
			} `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}