datalifecycle

Documentation

Index

• Constants
• Variables
• type Server
  • func NewServer(ingestJobClient ingest.JobSchedulerServiceClient, ...) *Server
  • func (s *Server) GetComplianceStatus(ctx context.Context, req *api.GetComplianceStatusRequest) (*api.GetComplianceStatusResponse, error)
  • func (s *Server) GetEventFeedStatus(ctx context.Context, req *api.GetEventFeedStatusRequest) (*api.GetEventFeedStatusResponse, error)
  • func (s *Server) GetInfraStatus(ctx context.Context, req *api.GetInfraStatusRequest) (*api.GetInfraStatusResponse, error)
  • func (s *Server) GetServicesStatus(ctx context.Context, req *api.GetServicesStatusRequest) (*api.GetServicesStatusResponse, error)
  • func (s *Server) GetStatus(ctx context.Context, req *api.GetStatusRequest) (*api.GetStatusResponse, error)
  • func (s *Server) Run(ctx context.Context, req *api.RunRequest) (*api.RunResponse, error)
  • func (s *Server) RunCompliance(ctx context.Context, req *api.RunComplianceRequest) (*api.RunComplianceResponse, error)
  • func (s *Server) RunEventFeed(ctx context.Context, req *api.RunEventFeedRequest) (*api.RunEventFeedResponse, error)
  • func (s *Server) RunInfra(ctx context.Context, req *api.RunInfraRequest) (*api.RunInfraResponse, error)
  • func (s *Server) RunServices(ctx context.Context, req *api.RunServicesRequest) (*api.RunServicesResponse, error)
  • func (s *Server) SetComplianceConfig(ctx context.Context, req *api.SetComplianceConfigRequest) (*api.SetComplianceConfigResponse, error)
  • func (s *Server) SetConfig(ctx context.Context, req *api.SetConfigRequest) (*api.SetConfigResponse, error)
  • func (s *Server) SetEventFeedConfig(ctx context.Context, req *api.SetEventFeedConfigRequest) (*api.SetEventFeedConfigResponse, error)
  • func (s *Server) SetInfraConfig(ctx context.Context, req *api.SetInfraConfigRequest) (*api.SetInfraConfigResponse, error)
  • func (s *Server) SetServicesConfig(ctx context.Context, req *api.SetServicesConfigRequest) (*api.SetServicesConfigResponse, error)

Constants

const (
	DisconnectedServicesJobName       = "disconnected_services"
	DeleteDisconnectedServicesJobName = "delete_disconnected_services"
)

if a new one is added here, add it to ValidServicesJobNames below so our error message stays correct

Variables

var ValidServicesJobNames = []string{
	DisconnectedServicesJobName,
	DeleteDisconnectedServicesJobName,
}

Types

type Server

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

Server is the data lifecycle server handler implementation

func NewServer

func NewServer(ingestJobClient ingest.JobSchedulerServiceClient,
	ingestPurgeClient data_lifecycle.PurgeClient,
	compliancePurgeClient data_lifecycle.PurgeClient,
	eventFeedPurgeClient data_lifecycle.PurgeClient,
	appsClient apps.ApplicationsServiceClient,
) *Server

NewServer returns a pointer to a new instance of the Server

func (*Server) GetComplianceStatus

func (s *Server) GetComplianceStatus(ctx context.Context, req *api.GetComplianceStatusRequest) (*api.GetComplianceStatusResponse, error)

GetComplianceStatus returns the compliance purge status

func (*Server) GetEventFeedStatus

func (s *Server) GetEventFeedStatus(ctx context.Context, req *api.GetEventFeedStatusRequest) (*api.GetEventFeedStatusResponse, error)

GetEventFeedStatus returns the event feed purge status

func (*Server) GetInfraStatus

func (s *Server) GetInfraStatus(ctx context.Context, req *api.GetInfraStatusRequest) (*api.GetInfraStatusResponse, error)

GetInfraStatus returns the infra job statuses by combining the nodes missing, nodes deleting, nodes missing deleting, and infra purge workflows details.

func (*Server) GetServicesStatus

func (s *Server) GetServicesStatus(ctx context.Context, req *api.GetServicesStatusRequest) (*api.GetServicesStatusResponse, error)

GetServicesStatus returns the applications data lifecycle status

func (*Server) GetStatus

func (s *Server) GetStatus(ctx context.Context, req *api.GetStatusRequest) (*api.GetStatusResponse, error)

GetStatus returns the aggregate status across all data lifecycle schedules and configuration.

func (*Server) Run

func (s *Server) Run(ctx context.Context, req *api.RunRequest) (*api.RunResponse, error)

Run runs all data lifecycle jobs

func (*Server) RunCompliance

func (s *Server) RunCompliance(ctx context.Context, req *api.RunComplianceRequest) (*api.RunComplianceResponse, error)

RunCompliance runs the compliance data purge

func (*Server) RunEventFeed

func (s *Server) RunEventFeed(ctx context.Context, req *api.RunEventFeedRequest) (*api.RunEventFeedResponse, error)

RunEventFeed runs the event feed data purge

func (*Server) RunInfra

func (s *Server) RunInfra(ctx context.Context, req *api.RunInfraRequest) (*api.RunInfraResponse, error)

RunInfra runs all of the infra data lifecycle jobs

func (*Server) RunServices

func (s *Server) RunServices(ctx context.Context, req *api.RunServicesRequest) (*api.RunServicesResponse, error)

RunServices runs the applications data life cycle jobs

func (*Server) SetComplianceConfig

func (s *Server) SetComplianceConfig(ctx context.Context, req *api.SetComplianceConfigRequest) (*api.SetComplianceConfigResponse, error)

SetComplianceConfig configures the compliance purge policies

func (*Server) SetConfig

func (s *Server) SetConfig(ctx context.Context, req *api.SetConfigRequest) (*api.SetConfigResponse, error)

SetConfig configures all data lifecycle jobs

func (*Server) SetEventFeedConfig

func (s *Server) SetEventFeedConfig(ctx context.Context, req *api.SetEventFeedConfigRequest) (*api.SetEventFeedConfigResponse, error)

SetEventFeedConfig configures the event feed purge policies

func (*Server) SetInfraConfig

func (s *Server) SetInfraConfig(ctx context.Context, req *api.SetInfraConfigRequest) (*api.SetInfraConfigResponse, error)

SetInfraConfig configures all data lifecycle jobs

func (*Server) SetServicesConfig

func (s *Server) SetServicesConfig(ctx context.Context, req *api.SetServicesConfigRequest) (*api.SetServicesConfigResponse, error)

SetServicesConfig configures the applications data lifecycle jobs