elastic

Documentation

Index

• type Blob
• type ElasticIndexer
  • func (this *ElasticIndexer) Start() error
  • func (this *ElasticIndexer) Stop() error
• type ElasticModule
  • func (module ElasticModule) Init()
  • func (module ElasticModule) Name() string
  • func (module ElasticModule) Setup(cfg *config.Config)
  • func (module ElasticModule) Start() error
  • func (module ElasticModule) Stop() error
• type ElasticORM
  • func (handler ElasticORM) Count(o interface{}) (int, error)
  • func (handler ElasticORM) Delete(o interface{}) error
  • func (handler ElasticORM) Get(o interface{}) error
  • func (handler ElasticORM) GetBy(field string, value interface{}, t interface{}, to interface{}) (error, api.Result)
  • func (handler ElasticORM) GroupBy(t interface{}, selectField, groupField string, haveQuery string, ...) (error, map[string]interface{})
  • func (handler ElasticORM) RegisterSchema(t interface{}) error
  • func (handler ElasticORM) Save(o interface{}) error
  • func (handler ElasticORM) Search(t interface{}, to interface{}, q *api.Query) (error, api.Result)
  • func (handler ElasticORM) Update(o interface{}) error
• type ElasticStore
  • func (store ElasticStore) AddValue(bucket string, key []byte, value []byte) error
  • func (store ElasticStore) AddValueCompress(bucket string, key []byte, value []byte) error
  • func (store ElasticStore) Close() error
  • func (store ElasticStore) DeleteBucket(bucket string) error
  • func (store ElasticStore) DeleteKey(bucket string, key []byte) error
  • func (store ElasticStore) GetCompressedValue(bucket string, key []byte) ([]byte, error)
  • func (store ElasticStore) GetValue(bucket string, key []byte) ([]byte, error)
  • func (store ElasticStore) Open() error
• type ModuleConfig

Types

type Blob

type Blob struct {
	Content string `json:"content,omitempty" elastic_mapping:"content: { type: binary, doc_values:false }"`
}

type ElasticIndexer

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

func (*ElasticIndexer) Start

func (this *ElasticIndexer) Start() error

func (*ElasticIndexer) Stop

func (this *ElasticIndexer) Stop() error

type ElasticModule

type ElasticModule struct {
}

func (ElasticModule) Init

func (module ElasticModule) Init()

func (ElasticModule) Name

func (module ElasticModule) Name() string

func (ElasticModule) Setup

func (module ElasticModule) Setup(cfg *config.Config)

func (ElasticModule) Start

func (module ElasticModule) Start() error

func (ElasticModule) Stop

func (module ElasticModule) Stop() error

type ElasticORM

type ElasticORM struct {
	Client elastic.API
}

func (ElasticORM) Count

func (handler ElasticORM) Count(o interface{}) (int, error)

func (ElasticORM) Delete

func (handler ElasticORM) Delete(o interface{}) error

func (ElasticORM) Get

func (handler ElasticORM) Get(o interface{}) error

func (ElasticORM) GetBy

func (handler ElasticORM) GetBy(field string, value interface{}, t interface{}, to interface{}) (error, api.Result)

func (ElasticORM) GroupBy

func (handler ElasticORM) GroupBy(t interface{}, selectField, groupField string, haveQuery string, haveValue interface{}) (error, map[string]interface{})

func (ElasticORM) RegisterSchema

func (handler ElasticORM) RegisterSchema(t interface{}) error

elastic_mapping:"content: { type: binary, doc_values:false }"

func (ElasticORM) Save

func (handler ElasticORM) Save(o interface{}) error

func (ElasticORM) Search

func (handler ElasticORM) Search(t interface{}, to interface{}, q *api.Query) (error, api.Result)

func (ElasticORM) Update

func (handler ElasticORM) Update(o interface{}) error

type ElasticStore

type ElasticStore struct {
	Client elastic.API
}

func (ElasticStore) AddValue

func (store ElasticStore) AddValue(bucket string, key []byte, value []byte) error

func (ElasticStore) AddValueCompress

func (store ElasticStore) AddValueCompress(bucket string, key []byte, value []byte) error

func (ElasticStore) Close

func (store ElasticStore) Close() error

func (ElasticStore) DeleteBucket

func (store ElasticStore) DeleteBucket(bucket string) error

func (ElasticStore) DeleteKey

func (store ElasticStore) DeleteKey(bucket string, key []byte) error

func (ElasticStore) GetCompressedValue

func (store ElasticStore) GetCompressedValue(bucket string, key []byte) ([]byte, error)

func (ElasticStore) GetValue

func (store ElasticStore) GetValue(bucket string, key []byte) ([]byte, error)

func (ElasticStore) Open

func (store ElasticStore) Open() error

type ModuleConfig

type ModuleConfig struct {
	IndexerEnabled bool   `config:"indexer_enabled"`
	StoreEnabled   bool   `config:"store_enabled"`
	ORMEnabled     bool   `config:"orm_enabled"`
	Elasticsearch  string `config:"elasticsearch"`
}