event

Documentation

Index

• Constants
• type EventRepository
  • func NewEventRepository(influxDBCfg *InternalInflux.Config) *EventRepository
  • func (e *EventRepository) CreateEvents(in *datahub_v1alpha1.CreateEventsRequest) error
  • func (e *EventRepository) ListEvents(in *datahub_v1alpha1.ListEventsRequest) ([]*datahub_v1alpha1.Event, error)

Constants

const (
	Event influxdb.Measurement = "event"
)

Types

type EventRepository

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

func NewEventRepository

func NewEventRepository(influxDBCfg *InternalInflux.Config) *EventRepository

func (*EventRepository) CreateEvents

func (e *EventRepository) CreateEvents(in *datahub_v1alpha1.CreateEventsRequest) error

func (*EventRepository) ListEvents

func (e *EventRepository) ListEvents(in *datahub_v1alpha1.ListEventsRequest) ([]*datahub_v1alpha1.Event, error)