Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrorEventIDEmpty = errors.New("event IDs are not supposed to be empty") ErrorEventPayloadEmpty = errors.New("event payload is nil") ErrorEventPayloadInvalid = errors.New("payload is not valid") ErrorNegativeStatusCode = errors.New("opensearch replied with a negative status code") )
View Source
var ErrOptNoAddress = errors.New("no address was specified")
Functions ¶
func EnsureIndexTemplate ¶
func EnsureIndexTemplate(ctx context.Context, client Client, config DataStream) error
EnsureIndexTemplate makes sure that an Index Template is present and is configured in a given way.
Note: If the configuration of an exisiting index template doesn't match the given configuration an error will be returned. Currently there is no save way for us to update the index template.
func IndexEvent ¶
IndexEvent takes a given Event and tries to appned it to the current stream
Types ¶
type Client ¶
type Client struct {
*opensearch.Client
}
Client is the way to communicate with a configured opensearch.
func NewWithDefaultClient ¶
NewWithDefaultClient creates a Client based on the given http.Client.
type DataStream ¶
type DataStream interface {
Name() string
}
type Document ¶
type Document interface {
// ID should return a unique ID for this document.
ID() string
// Index should return the target index
Index() string
// Data should return the docuemnt that should be indexed.
Data() interface{}
}
Document describes an indexable set of data.
type Event ¶
type Event struct {
ID string
Payload EventPayload
}
type EventPayload ¶
type EventPayload interface{}
Source Files
Click to show internal directories.
Click to hide internal directories.