search

Documentation

Index

• func Close()
• func InsertReaction(ctx context.Context, reaction domain.Reaction) error
• func PerformSearchReactions(ctx context.Context, query string, skip uint64, take uint64) ([]domain.Reaction, error)
• func SetRepository(repository Repository)
• type ElasticRepository
  • func NewElastic(url string) (*ElasticRepository, error)
  • func (r *ElasticRepository) Close()
  • func (r *ElasticRepository) InsertReaction(ctx context.Context, reaction domain.Reaction) error
  • func (r *ElasticRepository) SearchReactions(ctx context.Context, query string, skip uint64, take uint64) ([]domain.Reaction, error)
• type Repository

Functions

func Close

func Close()

Close ...

func InsertReaction

func InsertReaction(ctx context.Context, reaction domain.Reaction) error

InsertReaction ...

func PerformSearchReactions

func PerformSearchReactions(ctx context.Context, query string, skip uint64, take uint64) ([]domain.Reaction, error)

PerformSearchReactions ...

func SetRepository

func SetRepository(repository Repository)

SetRepository ...

Types

type ElasticRepository

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

ElasticRepository ...

func NewElastic

func NewElastic(url string) (*ElasticRepository, error)

NewElastic ...

func (*ElasticRepository) Close

func (r *ElasticRepository) Close()

Close ...

func (*ElasticRepository) InsertReaction

func (r *ElasticRepository) InsertReaction(ctx context.Context, reaction domain.Reaction) error

InsertReaction ...

func (*ElasticRepository) SearchReactions

func (r *ElasticRepository) SearchReactions(ctx context.Context, query string, skip uint64, take uint64) ([]domain.Reaction, error)

SearchReactions ...

type Repository

type Repository interface {
	Close()
	InsertReaction(ctx context.Context, reaction domain.Reaction) error
	SearchReactions(ctx context.Context, query string, skip uint64, take uint64) ([]domain.Reaction, error)
}

Repository ...