ingest

package
v0.0.0-...-be2ef80 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 23 Imported by: 9

Documentation

Overview

Package ingest is a generated GoMock package.

Package ingest is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package ingest is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package ingest is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_interservice_ingest_automate_event_proto protoreflect.FileDescriptor
View Source 
var File_interservice_ingest_chef_proto protoreflect.FileDescriptor
View Source 
var File_interservice_ingest_job_scheduler_proto protoreflect.FileDescriptor
View Source 
var File_interservice_ingest_status_proto protoreflect.FileDescriptor

Functions

func RegisterChefIngesterServiceHandler 

func RegisterChefIngesterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterChefIngesterServiceHandler registers the http handlers for service ChefIngesterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterChefIngesterServiceHandlerClient 

func RegisterChefIngesterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChefIngesterServiceClient) error

RegisterChefIngesterServiceHandlerClient registers the http handlers for service ChefIngesterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChefIngesterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChefIngesterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChefIngesterServiceClient" to call the correct interceptors.

func RegisterChefIngesterServiceHandlerFromEndpoint 

func RegisterChefIngesterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterChefIngesterServiceHandlerFromEndpoint is same as RegisterChefIngesterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterChefIngesterServiceHandlerServer 

func RegisterChefIngesterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChefIngesterServiceServer) error

RegisterChefIngesterServiceHandlerServer registers the http handlers for service ChefIngesterService to "mux". UnaryRPC :call ChefIngesterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterChefIngesterServiceServer 

func RegisterChefIngesterServiceServer(s *grpc.Server, srv ChefIngesterServiceServer)

func RegisterEventHandlerServiceServer 

func RegisterEventHandlerServiceServer(s *grpc.Server, srv EventHandlerServiceServer)

func RegisterIngestStatusServiceHandler 

func RegisterIngestStatusServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterIngestStatusServiceHandler registers the http handlers for service IngestStatusService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterIngestStatusServiceHandlerClient 

func RegisterIngestStatusServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IngestStatusServiceClient) error

RegisterIngestStatusServiceHandlerClient registers the http handlers for service IngestStatusService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "IngestStatusServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "IngestStatusServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "IngestStatusServiceClient" to call the correct interceptors.

func RegisterIngestStatusServiceHandlerFromEndpoint 

func RegisterIngestStatusServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterIngestStatusServiceHandlerFromEndpoint is same as RegisterIngestStatusServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterIngestStatusServiceHandlerServer 

func RegisterIngestStatusServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server IngestStatusServiceServer) error

RegisterIngestStatusServiceHandlerServer registers the http handlers for service IngestStatusService to "mux". UnaryRPC :call IngestStatusServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterIngestStatusServiceServer 

func RegisterIngestStatusServiceServer(s *grpc.Server, srv IngestStatusServiceServer)

func RegisterJobSchedulerServiceHandler 

func RegisterJobSchedulerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterJobSchedulerServiceHandler registers the http handlers for service JobSchedulerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterJobSchedulerServiceHandlerClient 

func RegisterJobSchedulerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobSchedulerServiceClient) error

RegisterJobSchedulerServiceHandlerClient registers the http handlers for service JobSchedulerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobSchedulerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobSchedulerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobSchedulerServiceClient" to call the correct interceptors.

func RegisterJobSchedulerServiceHandlerFromEndpoint 

func RegisterJobSchedulerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterJobSchedulerServiceHandlerFromEndpoint is same as RegisterJobSchedulerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterJobSchedulerServiceHandlerServer 

func RegisterJobSchedulerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobSchedulerServiceServer) error

RegisterJobSchedulerServiceHandlerServer registers the http handlers for service JobSchedulerService to "mux". UnaryRPC :call JobSchedulerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterJobSchedulerServiceServer 

func RegisterJobSchedulerServiceServer(s *grpc.Server, srv JobSchedulerServiceServer)

Types

type ChefIngesterServiceClient 

type ChefIngesterServiceClient interface {
	ProcessChefRun(ctx context.Context, in *request.Run, opts ...grpc.CallOption) (*response.ProcessChefRunResponse, error)
	ProcessChefAction(ctx context.Context, in *request.Action, opts ...grpc.CallOption) (*response.ProcessChefActionResponse, error)
	ProcessLivenessPing(ctx context.Context, in *request.Liveness, opts ...grpc.CallOption) (*response.ProcessLivenessResponse, error)
	ProcessMultipleNodeDeletes(ctx context.Context, in *request.MultipleNodeDeleteRequest, opts ...grpc.CallOption) (*response.ProcessMultipleNodeDeleteResponse, error)
	ProcessNodeDelete(ctx context.Context, in *request.Delete, opts ...grpc.CallOption) (*response.ProcessNodeDeleteResponse, error)
	GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*Version, error)
}

ChefIngesterServiceClient is the client API for ChefIngesterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewChefIngesterServiceClient 

func NewChefIngesterServiceClient(cc grpc.ClientConnInterface) ChefIngesterServiceClient

type ChefIngesterServiceServer 

type ChefIngesterServiceServer interface {
	ProcessChefRun(context.Context, *request.Run) (*response.ProcessChefRunResponse, error)
	ProcessChefAction(context.Context, *request.Action) (*response.ProcessChefActionResponse, error)
	ProcessLivenessPing(context.Context, *request.Liveness) (*response.ProcessLivenessResponse, error)
	ProcessMultipleNodeDeletes(context.Context, *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)
	ProcessNodeDelete(context.Context, *request.Delete) (*response.ProcessNodeDeleteResponse, error)
	GetVersion(context.Context, *VersionRequest) (*Version, error)
}

ChefIngesterServiceServer is the server API for ChefIngesterService service.

type ConfigureDeleteNodesSchedulerResponse 

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

func (*ConfigureDeleteNodesSchedulerResponse) Descriptor deprecated 

func (*ConfigureDeleteNodesSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureDeleteNodesSchedulerResponse.ProtoReflect.Descriptor instead.

func (*ConfigureDeleteNodesSchedulerResponse) ProtoMessage 

func (*ConfigureDeleteNodesSchedulerResponse) ProtoMessage()

func (*ConfigureDeleteNodesSchedulerResponse) ProtoReflect 

func (x *ConfigureDeleteNodesSchedulerResponse) ProtoReflect() protoreflect.Message

func (*ConfigureDeleteNodesSchedulerResponse) Reset 

func (x *ConfigureDeleteNodesSchedulerResponse) Reset()

func (*ConfigureDeleteNodesSchedulerResponse) String 

func (x *ConfigureDeleteNodesSchedulerResponse) String() string

type ConfigureMissingNodesForDeletionSchedulerResponse 

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

func (*ConfigureMissingNodesForDeletionSchedulerResponse) Descriptor deprecated 

func (*ConfigureMissingNodesForDeletionSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureMissingNodesForDeletionSchedulerResponse.ProtoReflect.Descriptor instead.

func (*ConfigureMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*ConfigureMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*ConfigureMissingNodesForDeletionSchedulerResponse) ProtoReflect 

func (x *ConfigureMissingNodesForDeletionSchedulerResponse) ProtoReflect() protoreflect.Message

func (*ConfigureMissingNodesForDeletionSchedulerResponse) Reset 

func (x *ConfigureMissingNodesForDeletionSchedulerResponse) Reset()

func (*ConfigureMissingNodesForDeletionSchedulerResponse) String 

func (x *ConfigureMissingNodesForDeletionSchedulerResponse) String() string

type ConfigureNodesMissingSchedulerResponse 

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

func (*ConfigureNodesMissingSchedulerResponse) Descriptor deprecated 

func (*ConfigureNodesMissingSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureNodesMissingSchedulerResponse.ProtoReflect.Descriptor instead.

func (*ConfigureNodesMissingSchedulerResponse) ProtoMessage 

func (*ConfigureNodesMissingSchedulerResponse) ProtoMessage()

func (*ConfigureNodesMissingSchedulerResponse) ProtoReflect 

func (x *ConfigureNodesMissingSchedulerResponse) ProtoReflect() protoreflect.Message

func (*ConfigureNodesMissingSchedulerResponse) Reset 

func (x *ConfigureNodesMissingSchedulerResponse) Reset()

func (*ConfigureNodesMissingSchedulerResponse) String 

func (x *ConfigureNodesMissingSchedulerResponse) String() string

type DeleteMarkedNodesRequest 

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

DeleteNodesScheduler

func (*DeleteMarkedNodesRequest) Descriptor deprecated 

func (*DeleteMarkedNodesRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteMarkedNodesRequest.ProtoReflect.Descriptor instead.

func (*DeleteMarkedNodesRequest) ProtoMessage 

func (*DeleteMarkedNodesRequest) ProtoMessage()

func (*DeleteMarkedNodesRequest) ProtoReflect 

func (x *DeleteMarkedNodesRequest) ProtoReflect() protoreflect.Message

func (*DeleteMarkedNodesRequest) Reset 

func (x *DeleteMarkedNodesRequest) Reset()

func (*DeleteMarkedNodesRequest) String 

func (x *DeleteMarkedNodesRequest) String() string

type DeleteMarkedNodesResponse 

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

func (*DeleteMarkedNodesResponse) Descriptor deprecated 

func (*DeleteMarkedNodesResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteMarkedNodesResponse.ProtoReflect.Descriptor instead.

func (*DeleteMarkedNodesResponse) ProtoMessage 

func (*DeleteMarkedNodesResponse) ProtoMessage()

func (*DeleteMarkedNodesResponse) ProtoReflect 

func (x *DeleteMarkedNodesResponse) ProtoReflect() protoreflect.Message

func (*DeleteMarkedNodesResponse) Reset 

func (x *DeleteMarkedNodesResponse) Reset()

func (*DeleteMarkedNodesResponse) String 

func (x *DeleteMarkedNodesResponse) String() string

type EventHandlerServiceClient 

type EventHandlerServiceClient interface {
	HandleEvent(ctx context.Context, in *event.EventMsg, opts ...grpc.CallOption) (*event.EventResponse, error)
	ProjectUpdateStatus(ctx context.Context, in *ProjectUpdateStatusReq, opts ...grpc.CallOption) (*ProjectUpdateStatusResp, error)
}

EventHandlerServiceClient is the client API for EventHandlerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventHandlerServiceClient 

func NewEventHandlerServiceClient(cc grpc.ClientConnInterface) EventHandlerServiceClient

type EventHandlerServiceServer 

type EventHandlerServiceServer interface {
	HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, error)
	ProjectUpdateStatus(context.Context, *ProjectUpdateStatusReq) (*ProjectUpdateStatusResp, error)
}

EventHandlerServiceServer is the server API for EventHandlerService service.

type Health 

type Health struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	// contains filtered or unexported fields
}

Health message

The ingest-service health is constructed with:

  • Status: => ok: Everything is alright => initialization: The service is in its initialization process => warning: Something might be wrong? => critical: Something is wrong!

@afiune: Here we can add more health information to the response

func (*Health) Descriptor deprecated 

func (*Health) Descriptor() ([]byte, []int)

Deprecated: Use Health.ProtoReflect.Descriptor instead.

func (*Health) GetStatus 

func (x *Health) GetStatus() string

func (*Health) ProtoMessage 

func (*Health) ProtoMessage()

func (*Health) ProtoReflect 

func (x *Health) ProtoReflect() protoreflect.Message

func (*Health) Reset 

func (x *Health) Reset()

func (*Health) String 

func (x *Health) String() string

type HealthRequest 

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

func (*HealthRequest) Descriptor deprecated 

func (*HealthRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) ProtoReflect 

func (x *HealthRequest) ProtoReflect() protoreflect.Message

func (*HealthRequest) Reset 

func (x *HealthRequest) Reset()

func (*HealthRequest) String 

func (x *HealthRequest) String() string

type IngestStatusServiceClient 

type IngestStatusServiceClient interface {
	GetMetrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*Metrics, error)
	GetHealth(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*Health, error)
	GetMigrationStatus(ctx context.Context, in *MigrationStatusRequest, opts ...grpc.CallOption) (*MigrationStatus, error)
}

IngestStatusServiceClient is the client API for IngestStatusService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngestStatusServiceClient 

func NewIngestStatusServiceClient(cc grpc.ClientConnInterface) IngestStatusServiceClient

type IngestStatusServiceServer 

type IngestStatusServiceServer interface {
	GetMetrics(context.Context, *MetricsRequest) (*Metrics, error)
	GetHealth(context.Context, *HealthRequest) (*Health, error)
	GetMigrationStatus(context.Context, *MigrationStatusRequest) (*MigrationStatus, error)
}

IngestStatusServiceServer is the server API for IngestStatusService service.

type Job 

type Job struct {
	Running     bool   `` /* 126-byte string literal not displayed */
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Every       string `protobuf:"bytes,3,opt,name=every,proto3" json:"every,omitempty" toml:"every,omitempty" mapstructure:"every,omitempty"`
	LastRun     string `` /* 142-byte string literal not displayed */
	NextRun     string `` /* 142-byte string literal not displayed */
	LastElapsed string `` /* 162-byte string literal not displayed */
	StartedOn   string `` /* 152-byte string literal not displayed */
	Threshold   string `` /* 133-byte string literal not displayed */
	Recurrence  string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetEvery 

func (x *Job) GetEvery() string

func (*Job) GetLastElapsed 

func (x *Job) GetLastElapsed() string

func (*Job) GetLastRun 

func (x *Job) GetLastRun() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetNextRun 

func (x *Job) GetNextRun() string

func (*Job) GetRecurrence 

func (x *Job) GetRecurrence() string

func (*Job) GetRunning 

func (x *Job) GetRunning() bool

func (*Job) GetStartedOn 

func (x *Job) GetStartedOn() string

func (*Job) GetThreshold 

func (x *Job) GetThreshold() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobSchedulerServiceClient 

type JobSchedulerServiceClient interface {
	GetStatusJobScheduler(ctx context.Context, in *JobSchedulerStatusRequest, opts ...grpc.CallOption) (*JobSchedulerStatus, error)
	MarkNodesMissing(ctx context.Context, in *MarkNodesMissingRequest, opts ...grpc.CallOption) (*MarkNodesMissingResponse, error)
	ConfigureNodesMissingScheduler(ctx context.Context, in *JobSettings, opts ...grpc.CallOption) (*ConfigureNodesMissingSchedulerResponse, error)
	StartNodesMissingScheduler(ctx context.Context, in *StartNodesMissingSchedulerRequest, opts ...grpc.CallOption) (*StartNodesMissingSchedulerResponse, error)
	StopNodesMissingScheduler(ctx context.Context, in *StopNodesMissingSchedulerRequest, opts ...grpc.CallOption) (*StopNodesMissingSchedulerResponse, error)
	// DeleteNodesScheduler
	DeleteMarkedNodes(ctx context.Context, in *DeleteMarkedNodesRequest, opts ...grpc.CallOption) (*DeleteMarkedNodesResponse, error)
	StartDeleteNodesScheduler(ctx context.Context, in *StartDeleteNodesSchedulerRequest, opts ...grpc.CallOption) (*StartDeleteNodesSchedulerResponse, error)
	StopDeleteNodesScheduler(ctx context.Context, in *StopDeleteNodesSchedulerRequest, opts ...grpc.CallOption) (*StopDeleteNodesSchedulerResponse, error)
	ConfigureDeleteNodesScheduler(ctx context.Context, in *JobSettings, opts ...grpc.CallOption) (*ConfigureDeleteNodesSchedulerResponse, error)
	// MissingNodesForDeletionScheduler
	MarkMissingNodesForDeletion(ctx context.Context, in *MarkMissingNodesForDeletionRequest, opts ...grpc.CallOption) (*MarkMissingNodesForDeletionResponse, error)
	ConfigureMissingNodesForDeletionScheduler(ctx context.Context, in *JobSettings, opts ...grpc.CallOption) (*ConfigureMissingNodesForDeletionSchedulerResponse, error)
	StartMissingNodesForDeletionScheduler(ctx context.Context, in *StartMissingNodesForDeletionSchedulerRequest, opts ...grpc.CallOption) (*StartMissingNodesForDeletionSchedulerResponse, error)
	StopMissingNodesForDeletionScheduler(ctx context.Context, in *StopMissingNodesForDeletionSchedulerRequest, opts ...grpc.CallOption) (*StopMissingNodesForDeletionSchedulerResponse, error)
}

JobSchedulerServiceClient is the client API for JobSchedulerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJobSchedulerServiceClient 

func NewJobSchedulerServiceClient(cc grpc.ClientConnInterface) JobSchedulerServiceClient

type JobSchedulerServiceServer 

type JobSchedulerServiceServer interface {
	GetStatusJobScheduler(context.Context, *JobSchedulerStatusRequest) (*JobSchedulerStatus, error)
	MarkNodesMissing(context.Context, *MarkNodesMissingRequest) (*MarkNodesMissingResponse, error)
	ConfigureNodesMissingScheduler(context.Context, *JobSettings) (*ConfigureNodesMissingSchedulerResponse, error)
	StartNodesMissingScheduler(context.Context, *StartNodesMissingSchedulerRequest) (*StartNodesMissingSchedulerResponse, error)
	StopNodesMissingScheduler(context.Context, *StopNodesMissingSchedulerRequest) (*StopNodesMissingSchedulerResponse, error)
	// DeleteNodesScheduler
	DeleteMarkedNodes(context.Context, *DeleteMarkedNodesRequest) (*DeleteMarkedNodesResponse, error)
	StartDeleteNodesScheduler(context.Context, *StartDeleteNodesSchedulerRequest) (*StartDeleteNodesSchedulerResponse, error)
	StopDeleteNodesScheduler(context.Context, *StopDeleteNodesSchedulerRequest) (*StopDeleteNodesSchedulerResponse, error)
	ConfigureDeleteNodesScheduler(context.Context, *JobSettings) (*ConfigureDeleteNodesSchedulerResponse, error)
	// MissingNodesForDeletionScheduler
	MarkMissingNodesForDeletion(context.Context, *MarkMissingNodesForDeletionRequest) (*MarkMissingNodesForDeletionResponse, error)
	ConfigureMissingNodesForDeletionScheduler(context.Context, *JobSettings) (*ConfigureMissingNodesForDeletionSchedulerResponse, error)
	StartMissingNodesForDeletionScheduler(context.Context, *StartMissingNodesForDeletionSchedulerRequest) (*StartMissingNodesForDeletionSchedulerResponse, error)
	StopMissingNodesForDeletionScheduler(context.Context, *StopMissingNodesForDeletionSchedulerRequest) (*StopMissingNodesForDeletionSchedulerResponse, error)
}

JobSchedulerServiceServer is the server API for JobSchedulerService service.

type JobSchedulerStatus 

type JobSchedulerStatus struct {
	Running bool   `` /* 126-byte string literal not displayed */
	Jobs    []*Job `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty" toml:"jobs,omitempty" mapstructure:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSchedulerStatus) Descriptor deprecated 

func (*JobSchedulerStatus) Descriptor() ([]byte, []int)

Deprecated: Use JobSchedulerStatus.ProtoReflect.Descriptor instead.

func (*JobSchedulerStatus) GetJobs 

func (x *JobSchedulerStatus) GetJobs() []*Job

func (*JobSchedulerStatus) GetRunning 

func (x *JobSchedulerStatus) GetRunning() bool

func (*JobSchedulerStatus) ProtoMessage 

func (*JobSchedulerStatus) ProtoMessage()

func (*JobSchedulerStatus) ProtoReflect 

func (x *JobSchedulerStatus) ProtoReflect() protoreflect.Message

func (*JobSchedulerStatus) Reset 

func (x *JobSchedulerStatus) Reset()

func (*JobSchedulerStatus) String 

func (x *JobSchedulerStatus) String() string

type JobSchedulerStatusRequest 

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

func (*JobSchedulerStatusRequest) Descriptor deprecated 

func (*JobSchedulerStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use JobSchedulerStatusRequest.ProtoReflect.Descriptor instead.

func (*JobSchedulerStatusRequest) ProtoMessage 

func (*JobSchedulerStatusRequest) ProtoMessage()

func (*JobSchedulerStatusRequest) ProtoReflect 

func (x *JobSchedulerStatusRequest) ProtoReflect() protoreflect.Message

func (*JobSchedulerStatusRequest) Reset 

func (x *JobSchedulerStatusRequest) Reset()

func (*JobSchedulerStatusRequest) String 

func (x *JobSchedulerStatusRequest) String() string

type JobSettings 

type JobSettings struct {
	Every     string `protobuf:"bytes,1,opt,name=every,proto3" json:"every,omitempty" toml:"every,omitempty" mapstructure:"every,omitempty"` // accepts '1h30m', '1m', '2h30m', ...
	Threshold string ``                                                                                                                      /* 133-byte string literal not displayed */
	Running   bool   ``                                                                                                                      /* 126-byte string literal not displayed */
	// recurrence rules are how underlying cereal workflow schedules are stored
	// and executed. 'every' was the scheduler format that was used in the
	// previous scheduler implementation and is still supported, though they
	// are translated to and from recurrence rules when getting and setting
	// the schedule recurrence.
	// When the UI is moved to the data_lifecycle top level api, which uses
	// recurrence, we can probably deprecate or remove every support.
	Recurrence string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

JobSettings - The job settings message to configure any scheduler job

func (*JobSettings) Descriptor deprecated 

func (*JobSettings) Descriptor() ([]byte, []int)

Deprecated: Use JobSettings.ProtoReflect.Descriptor instead.

func (*JobSettings) GetEvery 

func (x *JobSettings) GetEvery() string

func (*JobSettings) GetRecurrence 

func (x *JobSettings) GetRecurrence() string

func (*JobSettings) GetRunning 

func (x *JobSettings) GetRunning() bool

func (*JobSettings) GetThreshold 

func (x *JobSettings) GetThreshold() string

func (*JobSettings) ProtoMessage 

func (*JobSettings) ProtoMessage()

func (*JobSettings) ProtoReflect 

func (x *JobSettings) ProtoReflect() protoreflect.Message

func (*JobSettings) Reset 

func (x *JobSettings) Reset()

func (*JobSettings) String 

func (x *JobSettings) String() string

func (*JobSettings) Validate 

func (js *JobSettings) Validate() error

Validate is a helper function for the JobSettings proto message that will validate that every field has the right values, if one of them doesn't have a valid value then it will return an error with the problem and a suggestion to fix it

type MarkMissingNodesForDeletionRequest 

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

func (*MarkMissingNodesForDeletionRequest) Descriptor deprecated 

func (*MarkMissingNodesForDeletionRequest) Descriptor() ([]byte, []int)

Deprecated: Use MarkMissingNodesForDeletionRequest.ProtoReflect.Descriptor instead.

func (*MarkMissingNodesForDeletionRequest) ProtoMessage 

func (*MarkMissingNodesForDeletionRequest) ProtoMessage()

func (*MarkMissingNodesForDeletionRequest) ProtoReflect 

func (x *MarkMissingNodesForDeletionRequest) ProtoReflect() protoreflect.Message

func (*MarkMissingNodesForDeletionRequest) Reset 

func (x *MarkMissingNodesForDeletionRequest) Reset()

func (*MarkMissingNodesForDeletionRequest) String 

func (x *MarkMissingNodesForDeletionRequest) String() string

type MarkMissingNodesForDeletionResponse 

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

MissingNodesForDeletionScheduler

func (*MarkMissingNodesForDeletionResponse) Descriptor deprecated 

func (*MarkMissingNodesForDeletionResponse) Descriptor() ([]byte, []int)

Deprecated: Use MarkMissingNodesForDeletionResponse.ProtoReflect.Descriptor instead.

func (*MarkMissingNodesForDeletionResponse) ProtoMessage 

func (*MarkMissingNodesForDeletionResponse) ProtoMessage()

func (*MarkMissingNodesForDeletionResponse) ProtoReflect 

func (x *MarkMissingNodesForDeletionResponse) ProtoReflect() protoreflect.Message

func (*MarkMissingNodesForDeletionResponse) Reset 

func (x *MarkMissingNodesForDeletionResponse) Reset()

func (*MarkMissingNodesForDeletionResponse) String 

func (x *MarkMissingNodesForDeletionResponse) String() string

type MarkNodesMissingRequest 

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

NodesMissingScheduler

func (*MarkNodesMissingRequest) Descriptor deprecated 

func (*MarkNodesMissingRequest) Descriptor() ([]byte, []int)

Deprecated: Use MarkNodesMissingRequest.ProtoReflect.Descriptor instead.

func (*MarkNodesMissingRequest) ProtoMessage 

func (*MarkNodesMissingRequest) ProtoMessage()

func (*MarkNodesMissingRequest) ProtoReflect 

func (x *MarkNodesMissingRequest) ProtoReflect() protoreflect.Message

func (*MarkNodesMissingRequest) Reset 

func (x *MarkNodesMissingRequest) Reset()

func (*MarkNodesMissingRequest) String 

func (x *MarkNodesMissingRequest) String() string

type MarkNodesMissingResponse 

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

func (*MarkNodesMissingResponse) Descriptor deprecated 

func (*MarkNodesMissingResponse) Descriptor() ([]byte, []int)

Deprecated: Use MarkNodesMissingResponse.ProtoReflect.Descriptor instead.

func (*MarkNodesMissingResponse) ProtoMessage 

func (*MarkNodesMissingResponse) ProtoMessage()

func (*MarkNodesMissingResponse) ProtoReflect 

func (x *MarkNodesMissingResponse) ProtoReflect() protoreflect.Message

func (*MarkNodesMissingResponse) Reset 

func (x *MarkNodesMissingResponse) Reset()

func (*MarkNodesMissingResponse) String 

func (x *MarkNodesMissingResponse) String() string

type Metrics 

type Metrics struct {
	Uptime   float64          `protobuf:"fixed64,5,opt,name=uptime,proto3" json:"uptime,omitempty" toml:"uptime,omitempty" mapstructure:"uptime,omitempty"`
	Pipeline *PipelineMetrics `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metrics message

func (*Metrics) Descriptor deprecated 

func (*Metrics) Descriptor() ([]byte, []int)

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetPipeline 

func (x *Metrics) GetPipeline() *PipelineMetrics

func (*Metrics) GetUptime 

func (x *Metrics) GetUptime() float64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

func (x *Metrics) ProtoReflect() protoreflect.Message

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type MetricsRequest 

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

func (*MetricsRequest) Descriptor deprecated 

func (*MetricsRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect 

func (x *MetricsRequest) ProtoReflect() protoreflect.Message

func (*MetricsRequest) Reset 

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (x *MetricsRequest) String() string

type MigrationStatus 

type MigrationStatus struct {
	Total     int64  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty" toml:"total,omitempty" mapstructure:"total,omitempty"`
	Completed int64  `` /* 134-byte string literal not displayed */
	Status    string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	Finished  bool   `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

Migration message

func (*MigrationStatus) Descriptor deprecated 

func (*MigrationStatus) Descriptor() ([]byte, []int)

Deprecated: Use MigrationStatus.ProtoReflect.Descriptor instead.

func (*MigrationStatus) GetCompleted 

func (x *MigrationStatus) GetCompleted() int64

func (*MigrationStatus) GetFinished 

func (x *MigrationStatus) GetFinished() bool

func (*MigrationStatus) GetStatus 

func (x *MigrationStatus) GetStatus() string

func (*MigrationStatus) GetTotal 

func (x *MigrationStatus) GetTotal() int64

func (*MigrationStatus) ProtoMessage 

func (*MigrationStatus) ProtoMessage()

func (*MigrationStatus) ProtoReflect 

func (x *MigrationStatus) ProtoReflect() protoreflect.Message

func (*MigrationStatus) Reset 

func (x *MigrationStatus) Reset()

func (*MigrationStatus) String 

func (x *MigrationStatus) String() string

type MigrationStatusRequest 

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

func (*MigrationStatusRequest) Descriptor deprecated 

func (*MigrationStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrationStatusRequest.ProtoReflect.Descriptor instead.

func (*MigrationStatusRequest) ProtoMessage 

func (*MigrationStatusRequest) ProtoMessage()

func (*MigrationStatusRequest) ProtoReflect 

func (x *MigrationStatusRequest) ProtoReflect() protoreflect.Message

func (*MigrationStatusRequest) Reset 

func (x *MigrationStatusRequest) Reset()

func (*MigrationStatusRequest) String 

func (x *MigrationStatusRequest) String() string

type MockChefIngesterServiceClient 

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

MockChefIngesterServiceClient is a mock of ChefIngesterServiceClient interface.

func NewMockChefIngesterServiceClient 

func NewMockChefIngesterServiceClient(ctrl *gomock.Controller) *MockChefIngesterServiceClient

NewMockChefIngesterServiceClient creates a new mock instance.

func (*MockChefIngesterServiceClient) EXPECT 

func (m *MockChefIngesterServiceClient) EXPECT() *MockChefIngesterServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockChefIngesterServiceClient) GetVersion 

func (m *MockChefIngesterServiceClient) GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*Version, error)

GetVersion mocks base method.

func (*MockChefIngesterServiceClient) ProcessChefAction 

func (m *MockChefIngesterServiceClient) ProcessChefAction(ctx context.Context, in *request.Action, opts ...grpc.CallOption) (*response.ProcessChefActionResponse, error)

ProcessChefAction mocks base method.

func (*MockChefIngesterServiceClient) ProcessChefRun 

func (m *MockChefIngesterServiceClient) ProcessChefRun(ctx context.Context, in *request.Run, opts ...grpc.CallOption) (*response.ProcessChefRunResponse, error)

ProcessChefRun mocks base method.

func (*MockChefIngesterServiceClient) ProcessLivenessPing 

func (m *MockChefIngesterServiceClient) ProcessLivenessPing(ctx context.Context, in *request.Liveness, opts ...grpc.CallOption) (*response.ProcessLivenessResponse, error)

ProcessLivenessPing mocks base method.

func (*MockChefIngesterServiceClient) ProcessMultipleNodeDeletes 

func (m *MockChefIngesterServiceClient) ProcessMultipleNodeDeletes(ctx context.Context, in *request.MultipleNodeDeleteRequest, opts ...grpc.CallOption) (*response.ProcessMultipleNodeDeleteResponse, error)

ProcessMultipleNodeDeletes mocks base method.

func (*MockChefIngesterServiceClient) ProcessNodeDelete 

func (m *MockChefIngesterServiceClient) ProcessNodeDelete(ctx context.Context, in *request.Delete, opts ...grpc.CallOption) (*response.ProcessNodeDeleteResponse, error)

ProcessNodeDelete mocks base method.

type MockChefIngesterServiceClientMockRecorder 

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

MockChefIngesterServiceClientMockRecorder is the mock recorder for MockChefIngesterServiceClient.

func (*MockChefIngesterServiceClientMockRecorder) GetVersion 

func (mr *MockChefIngesterServiceClientMockRecorder) GetVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetVersion indicates an expected call of GetVersion.

func (*MockChefIngesterServiceClientMockRecorder) ProcessChefAction 

func (mr *MockChefIngesterServiceClientMockRecorder) ProcessChefAction(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessChefAction indicates an expected call of ProcessChefAction.

func (*MockChefIngesterServiceClientMockRecorder) ProcessChefRun 

func (mr *MockChefIngesterServiceClientMockRecorder) ProcessChefRun(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessChefRun indicates an expected call of ProcessChefRun.

func (*MockChefIngesterServiceClientMockRecorder) ProcessLivenessPing 

func (mr *MockChefIngesterServiceClientMockRecorder) ProcessLivenessPing(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessLivenessPing indicates an expected call of ProcessLivenessPing.

func (*MockChefIngesterServiceClientMockRecorder) ProcessMultipleNodeDeletes 

func (mr *MockChefIngesterServiceClientMockRecorder) ProcessMultipleNodeDeletes(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessMultipleNodeDeletes indicates an expected call of ProcessMultipleNodeDeletes.

func (*MockChefIngesterServiceClientMockRecorder) ProcessNodeDelete 

func (mr *MockChefIngesterServiceClientMockRecorder) ProcessNodeDelete(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessNodeDelete indicates an expected call of ProcessNodeDelete.

type MockChefIngesterServiceServer 

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

MockChefIngesterServiceServer is a mock of ChefIngesterServiceServer interface.

func NewMockChefIngesterServiceServer 

func NewMockChefIngesterServiceServer(ctrl *gomock.Controller) *MockChefIngesterServiceServer

NewMockChefIngesterServiceServer creates a new mock instance.

func (*MockChefIngesterServiceServer) EXPECT 

func (m *MockChefIngesterServiceServer) EXPECT() *MockChefIngesterServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockChefIngesterServiceServer) GetVersion 

func (m *MockChefIngesterServiceServer) GetVersion(arg0 context.Context, arg1 *VersionRequest) (*Version, error)

GetVersion mocks base method.

func (*MockChefIngesterServiceServer) ProcessChefAction 

func (m *MockChefIngesterServiceServer) ProcessChefAction(arg0 context.Context, arg1 *request.Action) (*response.ProcessChefActionResponse, error)

ProcessChefAction mocks base method.

func (*MockChefIngesterServiceServer) ProcessChefRun 

func (m *MockChefIngesterServiceServer) ProcessChefRun(arg0 context.Context, arg1 *request.Run) (*response.ProcessChefRunResponse, error)

ProcessChefRun mocks base method.

func (*MockChefIngesterServiceServer) ProcessLivenessPing 

func (m *MockChefIngesterServiceServer) ProcessLivenessPing(arg0 context.Context, arg1 *request.Liveness) (*response.ProcessLivenessResponse, error)

ProcessLivenessPing mocks base method.

func (*MockChefIngesterServiceServer) ProcessMultipleNodeDeletes 

func (m *MockChefIngesterServiceServer) ProcessMultipleNodeDeletes(arg0 context.Context, arg1 *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)

ProcessMultipleNodeDeletes mocks base method.

func (*MockChefIngesterServiceServer) ProcessNodeDelete 

func (m *MockChefIngesterServiceServer) ProcessNodeDelete(arg0 context.Context, arg1 *request.Delete) (*response.ProcessNodeDeleteResponse, error)

ProcessNodeDelete mocks base method.

type MockChefIngesterServiceServerMockRecorder 

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

MockChefIngesterServiceServerMockRecorder is the mock recorder for MockChefIngesterServiceServer.

func (*MockChefIngesterServiceServerMockRecorder) GetVersion 

func (mr *MockChefIngesterServiceServerMockRecorder) GetVersion(arg0, arg1 interface{}) *gomock.Call

GetVersion indicates an expected call of GetVersion.

func (*MockChefIngesterServiceServerMockRecorder) ProcessChefAction 

func (mr *MockChefIngesterServiceServerMockRecorder) ProcessChefAction(arg0, arg1 interface{}) *gomock.Call

ProcessChefAction indicates an expected call of ProcessChefAction.

func (*MockChefIngesterServiceServerMockRecorder) ProcessChefRun 

func (mr *MockChefIngesterServiceServerMockRecorder) ProcessChefRun(arg0, arg1 interface{}) *gomock.Call

ProcessChefRun indicates an expected call of ProcessChefRun.

func (*MockChefIngesterServiceServerMockRecorder) ProcessLivenessPing 

func (mr *MockChefIngesterServiceServerMockRecorder) ProcessLivenessPing(arg0, arg1 interface{}) *gomock.Call

ProcessLivenessPing indicates an expected call of ProcessLivenessPing.

func (*MockChefIngesterServiceServerMockRecorder) ProcessMultipleNodeDeletes 

func (mr *MockChefIngesterServiceServerMockRecorder) ProcessMultipleNodeDeletes(arg0, arg1 interface{}) *gomock.Call

ProcessMultipleNodeDeletes indicates an expected call of ProcessMultipleNodeDeletes.

func (*MockChefIngesterServiceServerMockRecorder) ProcessNodeDelete 

func (mr *MockChefIngesterServiceServerMockRecorder) ProcessNodeDelete(arg0, arg1 interface{}) *gomock.Call

ProcessNodeDelete indicates an expected call of ProcessNodeDelete.

type PipelineMetrics 

type PipelineMetrics struct {
	TotalRunMessages    int64 `` /* 192-byte string literal not displayed */
	TotalActionMessages int64 `` /* 207-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PipelineMetrics) Descriptor deprecated 

func (*PipelineMetrics) Descriptor() ([]byte, []int)

Deprecated: Use PipelineMetrics.ProtoReflect.Descriptor instead.

func (*PipelineMetrics) GetTotalActionMessages 

func (x *PipelineMetrics) GetTotalActionMessages() int64

func (*PipelineMetrics) GetTotalRunMessages 

func (x *PipelineMetrics) GetTotalRunMessages() int64

func (*PipelineMetrics) ProtoMessage 

func (*PipelineMetrics) ProtoMessage()

func (*PipelineMetrics) ProtoReflect 

func (x *PipelineMetrics) ProtoReflect() protoreflect.Message

func (*PipelineMetrics) Reset 

func (x *PipelineMetrics) Reset()

func (*PipelineMetrics) String 

func (x *PipelineMetrics) String() string

type ProjectUpdateStatusReq 

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

func (*ProjectUpdateStatusReq) Descriptor deprecated 

func (*ProjectUpdateStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use ProjectUpdateStatusReq.ProtoReflect.Descriptor instead.

func (*ProjectUpdateStatusReq) ProtoMessage 

func (*ProjectUpdateStatusReq) ProtoMessage()

func (*ProjectUpdateStatusReq) ProtoReflect 

func (x *ProjectUpdateStatusReq) ProtoReflect() protoreflect.Message

func (*ProjectUpdateStatusReq) Reset 

func (x *ProjectUpdateStatusReq) Reset()

func (*ProjectUpdateStatusReq) String 

func (x *ProjectUpdateStatusReq) String() string

type ProjectUpdateStatusResp 

type ProjectUpdateStatusResp struct {
	State                 string                 `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty" toml:"state,omitempty" mapstructure:"state,omitempty"`
	EstimatedTimeComplete *timestamppb.Timestamp `` /* 216-byte string literal not displayed */
	PercentageComplete    float32                `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProjectUpdateStatusResp) Descriptor deprecated 

func (*ProjectUpdateStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use ProjectUpdateStatusResp.ProtoReflect.Descriptor instead.

func (*ProjectUpdateStatusResp) GetEstimatedTimeComplete 

func (x *ProjectUpdateStatusResp) GetEstimatedTimeComplete() *timestamppb.Timestamp

func (*ProjectUpdateStatusResp) GetPercentageComplete 

func (x *ProjectUpdateStatusResp) GetPercentageComplete() float32

func (*ProjectUpdateStatusResp) GetState 

func (x *ProjectUpdateStatusResp) GetState() string

func (*ProjectUpdateStatusResp) ProtoMessage 

func (*ProjectUpdateStatusResp) ProtoMessage()

func (*ProjectUpdateStatusResp) ProtoReflect 

func (x *ProjectUpdateStatusResp) ProtoReflect() protoreflect.Message

func (*ProjectUpdateStatusResp) Reset 

func (x *ProjectUpdateStatusResp) Reset()

func (*ProjectUpdateStatusResp) String 

func (x *ProjectUpdateStatusResp) String() string

type StartDeleteNodesSchedulerRequest 

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

func (*StartDeleteNodesSchedulerRequest) Descriptor deprecated 

func (*StartDeleteNodesSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartDeleteNodesSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StartDeleteNodesSchedulerRequest) ProtoMessage 

func (*StartDeleteNodesSchedulerRequest) ProtoMessage()

func (*StartDeleteNodesSchedulerRequest) ProtoReflect 

func (x *StartDeleteNodesSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StartDeleteNodesSchedulerRequest) Reset 

func (x *StartDeleteNodesSchedulerRequest) Reset()

func (*StartDeleteNodesSchedulerRequest) String 

func (x *StartDeleteNodesSchedulerRequest) String() string

type StartDeleteNodesSchedulerResponse 

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

func (*StartDeleteNodesSchedulerResponse) Descriptor deprecated 

func (*StartDeleteNodesSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartDeleteNodesSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StartDeleteNodesSchedulerResponse) ProtoMessage 

func (*StartDeleteNodesSchedulerResponse) ProtoMessage()

func (*StartDeleteNodesSchedulerResponse) ProtoReflect 

func (x *StartDeleteNodesSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StartDeleteNodesSchedulerResponse) Reset 

func (x *StartDeleteNodesSchedulerResponse) Reset()

func (*StartDeleteNodesSchedulerResponse) String 

func (x *StartDeleteNodesSchedulerResponse) String() string

type StartJobSchedulerRequest 

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

func (*StartJobSchedulerRequest) Descriptor deprecated 

func (*StartJobSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartJobSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StartJobSchedulerRequest) ProtoMessage 

func (*StartJobSchedulerRequest) ProtoMessage()

func (*StartJobSchedulerRequest) ProtoReflect 

func (x *StartJobSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StartJobSchedulerRequest) Reset 

func (x *StartJobSchedulerRequest) Reset()

func (*StartJobSchedulerRequest) String 

func (x *StartJobSchedulerRequest) String() string

type StartJobSchedulerResponse 

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

func (*StartJobSchedulerResponse) Descriptor deprecated 

func (*StartJobSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartJobSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StartJobSchedulerResponse) ProtoMessage 

func (*StartJobSchedulerResponse) ProtoMessage()

func (*StartJobSchedulerResponse) ProtoReflect 

func (x *StartJobSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StartJobSchedulerResponse) Reset 

func (x *StartJobSchedulerResponse) Reset()

func (*StartJobSchedulerResponse) String 

func (x *StartJobSchedulerResponse) String() string

type StartMissingNodesForDeletionSchedulerRequest 

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

func (*StartMissingNodesForDeletionSchedulerRequest) Descriptor deprecated 

func (*StartMissingNodesForDeletionSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartMissingNodesForDeletionSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StartMissingNodesForDeletionSchedulerRequest) ProtoMessage 

func (*StartMissingNodesForDeletionSchedulerRequest) ProtoMessage()

func (*StartMissingNodesForDeletionSchedulerRequest) ProtoReflect 

func (x *StartMissingNodesForDeletionSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StartMissingNodesForDeletionSchedulerRequest) Reset 

func (x *StartMissingNodesForDeletionSchedulerRequest) Reset()

func (*StartMissingNodesForDeletionSchedulerRequest) String 

func (x *StartMissingNodesForDeletionSchedulerRequest) String() string

type StartMissingNodesForDeletionSchedulerResponse 

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

func (*StartMissingNodesForDeletionSchedulerResponse) Descriptor deprecated 

func (*StartMissingNodesForDeletionSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartMissingNodesForDeletionSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StartMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*StartMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*StartMissingNodesForDeletionSchedulerResponse) ProtoReflect 

func (x *StartMissingNodesForDeletionSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StartMissingNodesForDeletionSchedulerResponse) Reset 

func (x *StartMissingNodesForDeletionSchedulerResponse) Reset()

func (*StartMissingNodesForDeletionSchedulerResponse) String 

func (x *StartMissingNodesForDeletionSchedulerResponse) String() string

type StartNodesMissingSchedulerRequest 

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

func (*StartNodesMissingSchedulerRequest) Descriptor deprecated 

func (*StartNodesMissingSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartNodesMissingSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StartNodesMissingSchedulerRequest) ProtoMessage 

func (*StartNodesMissingSchedulerRequest) ProtoMessage()

func (*StartNodesMissingSchedulerRequest) ProtoReflect 

func (x *StartNodesMissingSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StartNodesMissingSchedulerRequest) Reset 

func (x *StartNodesMissingSchedulerRequest) Reset()

func (*StartNodesMissingSchedulerRequest) String 

func (x *StartNodesMissingSchedulerRequest) String() string

type StartNodesMissingSchedulerResponse 

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

func (*StartNodesMissingSchedulerResponse) Descriptor deprecated 

func (*StartNodesMissingSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartNodesMissingSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StartNodesMissingSchedulerResponse) ProtoMessage 

func (*StartNodesMissingSchedulerResponse) ProtoMessage()

func (*StartNodesMissingSchedulerResponse) ProtoReflect 

func (x *StartNodesMissingSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StartNodesMissingSchedulerResponse) Reset 

func (x *StartNodesMissingSchedulerResponse) Reset()

func (*StartNodesMissingSchedulerResponse) String 

func (x *StartNodesMissingSchedulerResponse) String() string

type StopDeleteNodesSchedulerRequest 

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

func (*StopDeleteNodesSchedulerRequest) Descriptor deprecated 

func (*StopDeleteNodesSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopDeleteNodesSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StopDeleteNodesSchedulerRequest) ProtoMessage 

func (*StopDeleteNodesSchedulerRequest) ProtoMessage()

func (*StopDeleteNodesSchedulerRequest) ProtoReflect 

func (x *StopDeleteNodesSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StopDeleteNodesSchedulerRequest) Reset 

func (x *StopDeleteNodesSchedulerRequest) Reset()

func (*StopDeleteNodesSchedulerRequest) String 

func (x *StopDeleteNodesSchedulerRequest) String() string

type StopDeleteNodesSchedulerResponse 

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

func (*StopDeleteNodesSchedulerResponse) Descriptor deprecated 

func (*StopDeleteNodesSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopDeleteNodesSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StopDeleteNodesSchedulerResponse) ProtoMessage 

func (*StopDeleteNodesSchedulerResponse) ProtoMessage()

func (*StopDeleteNodesSchedulerResponse) ProtoReflect 

func (x *StopDeleteNodesSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StopDeleteNodesSchedulerResponse) Reset 

func (x *StopDeleteNodesSchedulerResponse) Reset()

func (*StopDeleteNodesSchedulerResponse) String 

func (x *StopDeleteNodesSchedulerResponse) String() string

type StopJobSchedulerRequest 

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

func (*StopJobSchedulerRequest) Descriptor deprecated 

func (*StopJobSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopJobSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StopJobSchedulerRequest) ProtoMessage 

func (*StopJobSchedulerRequest) ProtoMessage()

func (*StopJobSchedulerRequest) ProtoReflect 

func (x *StopJobSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StopJobSchedulerRequest) Reset 

func (x *StopJobSchedulerRequest) Reset()

func (*StopJobSchedulerRequest) String 

func (x *StopJobSchedulerRequest) String() string

type StopJobSchedulerResponse 

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

func (*StopJobSchedulerResponse) Descriptor deprecated 

func (*StopJobSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopJobSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StopJobSchedulerResponse) ProtoMessage 

func (*StopJobSchedulerResponse) ProtoMessage()

func (*StopJobSchedulerResponse) ProtoReflect 

func (x *StopJobSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StopJobSchedulerResponse) Reset 

func (x *StopJobSchedulerResponse) Reset()

func (*StopJobSchedulerResponse) String 

func (x *StopJobSchedulerResponse) String() string

type StopMissingNodesForDeletionSchedulerRequest 

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

func (*StopMissingNodesForDeletionSchedulerRequest) Descriptor deprecated 

func (*StopMissingNodesForDeletionSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopMissingNodesForDeletionSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StopMissingNodesForDeletionSchedulerRequest) ProtoMessage 

func (*StopMissingNodesForDeletionSchedulerRequest) ProtoMessage()

func (*StopMissingNodesForDeletionSchedulerRequest) ProtoReflect 

func (x *StopMissingNodesForDeletionSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StopMissingNodesForDeletionSchedulerRequest) Reset 

func (x *StopMissingNodesForDeletionSchedulerRequest) Reset()

func (*StopMissingNodesForDeletionSchedulerRequest) String 

func (x *StopMissingNodesForDeletionSchedulerRequest) String() string

type StopMissingNodesForDeletionSchedulerResponse 

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

func (*StopMissingNodesForDeletionSchedulerResponse) Descriptor deprecated 

func (*StopMissingNodesForDeletionSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopMissingNodesForDeletionSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StopMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*StopMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*StopMissingNodesForDeletionSchedulerResponse) ProtoReflect 

func (x *StopMissingNodesForDeletionSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StopMissingNodesForDeletionSchedulerResponse) Reset 

func (x *StopMissingNodesForDeletionSchedulerResponse) Reset()

func (*StopMissingNodesForDeletionSchedulerResponse) String 

func (x *StopMissingNodesForDeletionSchedulerResponse) String() string

type StopNodesMissingSchedulerRequest 

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

func (*StopNodesMissingSchedulerRequest) Descriptor deprecated 

func (*StopNodesMissingSchedulerRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopNodesMissingSchedulerRequest.ProtoReflect.Descriptor instead.

func (*StopNodesMissingSchedulerRequest) ProtoMessage 

func (*StopNodesMissingSchedulerRequest) ProtoMessage()

func (*StopNodesMissingSchedulerRequest) ProtoReflect 

func (x *StopNodesMissingSchedulerRequest) ProtoReflect() protoreflect.Message

func (*StopNodesMissingSchedulerRequest) Reset 

func (x *StopNodesMissingSchedulerRequest) Reset()

func (*StopNodesMissingSchedulerRequest) String 

func (x *StopNodesMissingSchedulerRequest) String() string

type StopNodesMissingSchedulerResponse 

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

func (*StopNodesMissingSchedulerResponse) Descriptor deprecated 

func (*StopNodesMissingSchedulerResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopNodesMissingSchedulerResponse.ProtoReflect.Descriptor instead.

func (*StopNodesMissingSchedulerResponse) ProtoMessage 

func (*StopNodesMissingSchedulerResponse) ProtoMessage()

func (*StopNodesMissingSchedulerResponse) ProtoReflect 

func (x *StopNodesMissingSchedulerResponse) ProtoReflect() protoreflect.Message

func (*StopNodesMissingSchedulerResponse) Reset 

func (x *StopNodesMissingSchedulerResponse) Reset()

func (*StopNodesMissingSchedulerResponse) String 

func (x *StopNodesMissingSchedulerResponse) String() string

type UnimplementedChefIngesterServiceServer 

type UnimplementedChefIngesterServiceServer struct {
}

UnimplementedChefIngesterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedChefIngesterServiceServer) GetVersion 

func (*UnimplementedChefIngesterServiceServer) GetVersion(context.Context, *VersionRequest) (*Version, error)

func (*UnimplementedChefIngesterServiceServer) ProcessChefAction 

func (*UnimplementedChefIngesterServiceServer) ProcessChefAction(context.Context, *request.Action) (*response.ProcessChefActionResponse, error)

func (*UnimplementedChefIngesterServiceServer) ProcessChefRun 

func (*UnimplementedChefIngesterServiceServer) ProcessChefRun(context.Context, *request.Run) (*response.ProcessChefRunResponse, error)

func (*UnimplementedChefIngesterServiceServer) ProcessLivenessPing 

func (*UnimplementedChefIngesterServiceServer) ProcessLivenessPing(context.Context, *request.Liveness) (*response.ProcessLivenessResponse, error)

func (*UnimplementedChefIngesterServiceServer) ProcessMultipleNodeDeletes 

func (*UnimplementedChefIngesterServiceServer) ProcessMultipleNodeDeletes(context.Context, *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)

func (*UnimplementedChefIngesterServiceServer) ProcessNodeDelete 

func (*UnimplementedChefIngesterServiceServer) ProcessNodeDelete(context.Context, *request.Delete) (*response.ProcessNodeDeleteResponse, error)

type UnimplementedEventHandlerServiceServer 

type UnimplementedEventHandlerServiceServer struct {
}

UnimplementedEventHandlerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventHandlerServiceServer) HandleEvent 

func (*UnimplementedEventHandlerServiceServer) HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, error)

func (*UnimplementedEventHandlerServiceServer) ProjectUpdateStatus 

func (*UnimplementedEventHandlerServiceServer) ProjectUpdateStatus(context.Context, *ProjectUpdateStatusReq) (*ProjectUpdateStatusResp, error)

type UnimplementedIngestStatusServiceServer 

type UnimplementedIngestStatusServiceServer struct {
}

UnimplementedIngestStatusServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestStatusServiceServer) GetHealth 

func (*UnimplementedIngestStatusServiceServer) GetHealth(context.Context, *HealthRequest) (*Health, error)

func (*UnimplementedIngestStatusServiceServer) GetMetrics 

func (*UnimplementedIngestStatusServiceServer) GetMetrics(context.Context, *MetricsRequest) (*Metrics, error)

func (*UnimplementedIngestStatusServiceServer) GetMigrationStatus 

func (*UnimplementedIngestStatusServiceServer) GetMigrationStatus(context.Context, *MigrationStatusRequest) (*MigrationStatus, error)

type UnimplementedJobSchedulerServiceServer 

type UnimplementedJobSchedulerServiceServer struct {
}

UnimplementedJobSchedulerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobSchedulerServiceServer) ConfigureDeleteNodesScheduler 

func (*UnimplementedJobSchedulerServiceServer) ConfigureDeleteNodesScheduler(context.Context, *JobSettings) (*ConfigureDeleteNodesSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) ConfigureMissingNodesForDeletionScheduler 

func (*UnimplementedJobSchedulerServiceServer) ConfigureMissingNodesForDeletionScheduler(context.Context, *JobSettings) (*ConfigureMissingNodesForDeletionSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) ConfigureNodesMissingScheduler 

func (*UnimplementedJobSchedulerServiceServer) ConfigureNodesMissingScheduler(context.Context, *JobSettings) (*ConfigureNodesMissingSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) DeleteMarkedNodes 

func (*UnimplementedJobSchedulerServiceServer) DeleteMarkedNodes(context.Context, *DeleteMarkedNodesRequest) (*DeleteMarkedNodesResponse, error)

func (*UnimplementedJobSchedulerServiceServer) GetStatusJobScheduler 

func (*UnimplementedJobSchedulerServiceServer) GetStatusJobScheduler(context.Context, *JobSchedulerStatusRequest) (*JobSchedulerStatus, error)

func (*UnimplementedJobSchedulerServiceServer) MarkMissingNodesForDeletion 

func (*UnimplementedJobSchedulerServiceServer) MarkMissingNodesForDeletion(context.Context, *MarkMissingNodesForDeletionRequest) (*MarkMissingNodesForDeletionResponse, error)

func (*UnimplementedJobSchedulerServiceServer) MarkNodesMissing 

func (*UnimplementedJobSchedulerServiceServer) MarkNodesMissing(context.Context, *MarkNodesMissingRequest) (*MarkNodesMissingResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StartDeleteNodesScheduler 

func (*UnimplementedJobSchedulerServiceServer) StartDeleteNodesScheduler(context.Context, *StartDeleteNodesSchedulerRequest) (*StartDeleteNodesSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StartMissingNodesForDeletionScheduler 

func (*UnimplementedJobSchedulerServiceServer) StartMissingNodesForDeletionScheduler(context.Context, *StartMissingNodesForDeletionSchedulerRequest) (*StartMissingNodesForDeletionSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StartNodesMissingScheduler 

func (*UnimplementedJobSchedulerServiceServer) StartNodesMissingScheduler(context.Context, *StartNodesMissingSchedulerRequest) (*StartNodesMissingSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StopDeleteNodesScheduler 

func (*UnimplementedJobSchedulerServiceServer) StopDeleteNodesScheduler(context.Context, *StopDeleteNodesSchedulerRequest) (*StopDeleteNodesSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StopMissingNodesForDeletionScheduler 

func (*UnimplementedJobSchedulerServiceServer) StopMissingNodesForDeletionScheduler(context.Context, *StopMissingNodesForDeletionSchedulerRequest) (*StopMissingNodesForDeletionSchedulerResponse, error)

func (*UnimplementedJobSchedulerServiceServer) StopNodesMissingScheduler 

func (*UnimplementedJobSchedulerServiceServer) StopNodesMissingScheduler(context.Context, *StopNodesMissingSchedulerRequest) (*StopNodesMissingSchedulerResponse, error)

type Version 

type Version struct {
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty" mapstructure:"version,omitempty"`
	Built   string `protobuf:"bytes,1,opt,name=built,proto3" json:"built,omitempty" toml:"built,omitempty" mapstructure:"built,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Sha     string `protobuf:"bytes,4,opt,name=sha,proto3" json:"sha,omitempty" toml:"sha,omitempty" mapstructure:"sha,omitempty"`
	// contains filtered or unexported fields
}

Version message

The ingest-service version constructed with: * Service name * Built time * Semantic version * Git SHA

func (*Version) Descriptor deprecated 

func (*Version) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetBuilt 

func (x *Version) GetBuilt() string

func (*Version) GetName 

func (x *Version) GetName() string

func (*Version) GetSha 

func (x *Version) GetSha() string

func (*Version) GetVersion 

func (x *Version) GetVersion() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

type VersionRequest 

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

func (*VersionRequest) Descriptor deprecated 

func (*VersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

func (x *VersionRequest) ProtoReflect() protoreflect.Message

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) String 

func (x *VersionRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.