datalifecycle

package

v0.0.0-...-30e1f3d Latest Latest Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chef/automate

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Server
- func NewServer(ingestJobClient ingest.JobSchedulerServiceClient, ...) *Server

Constants ¶

View Source

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 ¶

View Source

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

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL