server

Documentation

Index

• type DataLifecycleManageableServer
  • func NewDataLifecycleManageableServer(purgeClient es.EsSidecarClient, purgePolicies []PurgePolicy) *DataLifecycleManageableServer
  • func (server *DataLifecycleManageableServer) Purge(ctx context.Context, request *dls.PurgeRequest) (*dls.PurgeResponse, error)
• type PurgePolicy

Types

type DataLifecycleManageableServer

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

func NewDataLifecycleManageableServer

func NewDataLifecycleManageableServer(purgeClient es.EsSidecarClient, purgePolicies []PurgePolicy) *DataLifecycleManageableServer

func (*DataLifecycleManageableServer) Purge

func (server *DataLifecycleManageableServer) Purge(ctx context.Context, request *dls.PurgeRequest) (*dls.PurgeResponse, error)

type PurgePolicy

type PurgePolicy struct {
	// PurgeOlderThanDays describes how long we keep data for either time series or non-time series indices. Anything
	// older than this is allowed to be regularly removed.
	PurgeOlderThanDays int32
	// IndexName is the base name of the time series index that should be purged
	IndexName string
	// Don't delete the entire index for non-time series databases; just delete documents over a given age from the index
	IsNonTimeSeries bool
	// IMPLEMENTED FOR NON-TIME SERIES INDICES ONLY!
	// Optional field. Purge documents based on the time value in this field rather than
	// the default field, end_time. Values for this field come from client purge policies.
	// If this field is empty, purge defaults to end_time.
	CustomPurgeField string
}