ingest

package
v0.0.0-...-0490640 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 23 Imported by: 0

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

This section is empty.

Functions

func RegisterChefIngesterHandler 

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

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

func RegisterChefIngesterHandlerClient 

func RegisterChefIngesterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChefIngesterClient) error

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

func RegisterChefIngesterHandlerFromEndpoint 

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

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

func RegisterChefIngesterServer 

func RegisterChefIngesterServer(s *grpc.Server, srv ChefIngesterServer)

func RegisterEventHandlerServer 

func RegisterEventHandlerServer(s *grpc.Server, srv EventHandlerServer)

func RegisterIngestStatusHandler 

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

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

func RegisterIngestStatusHandlerClient 

func RegisterIngestStatusHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IngestStatusClient) error

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

func RegisterIngestStatusHandlerFromEndpoint 

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

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

func RegisterIngestStatusServer 

func RegisterIngestStatusServer(s *grpc.Server, srv IngestStatusServer)

func RegisterJobSchedulerHandler 

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

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

func RegisterJobSchedulerHandlerClient 

func RegisterJobSchedulerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobSchedulerClient) error

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

func RegisterJobSchedulerHandlerFromEndpoint 

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

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

func RegisterJobSchedulerServer 

func RegisterJobSchedulerServer(s *grpc.Server, srv JobSchedulerServer)

Types

type ChefIngesterClient 

type ChefIngesterClient 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)
}

ChefIngesterClient is the client API for ChefIngester service.

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

func NewChefIngesterClient 

func NewChefIngesterClient(cc *grpc.ClientConn) ChefIngesterClient

type ChefIngesterServer 

type ChefIngesterServer 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)
}

ChefIngesterServer is the server API for ChefIngester service.

type ConfigureDeleteNodesSchedulerResponse 

type ConfigureDeleteNodesSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*ConfigureDeleteNodesSchedulerResponse) Descriptor 

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

func (*ConfigureDeleteNodesSchedulerResponse) ProtoMessage 

func (*ConfigureDeleteNodesSchedulerResponse) ProtoMessage()

func (*ConfigureDeleteNodesSchedulerResponse) Reset 

func (m *ConfigureDeleteNodesSchedulerResponse) Reset()

func (*ConfigureDeleteNodesSchedulerResponse) String 

func (m *ConfigureDeleteNodesSchedulerResponse) String() string

func (*ConfigureDeleteNodesSchedulerResponse) XXX_DiscardUnknown 

func (m *ConfigureDeleteNodesSchedulerResponse) XXX_DiscardUnknown()

func (*ConfigureDeleteNodesSchedulerResponse) XXX_Marshal 

func (m *ConfigureDeleteNodesSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureDeleteNodesSchedulerResponse) XXX_Merge 

func (dst *ConfigureDeleteNodesSchedulerResponse) XXX_Merge(src proto.Message)

func (*ConfigureDeleteNodesSchedulerResponse) XXX_Size 

func (m *ConfigureDeleteNodesSchedulerResponse) XXX_Size() int

func (*ConfigureDeleteNodesSchedulerResponse) XXX_Unmarshal 

func (m *ConfigureDeleteNodesSchedulerResponse) XXX_Unmarshal(b []byte) error

type ConfigureMissingNodesForDeletionSchedulerResponse 

type ConfigureMissingNodesForDeletionSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*ConfigureMissingNodesForDeletionSchedulerResponse) Descriptor 

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

func (*ConfigureMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*ConfigureMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*ConfigureMissingNodesForDeletionSchedulerResponse) Reset 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) Reset()

func (*ConfigureMissingNodesForDeletionSchedulerResponse) String 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) String() string

func (*ConfigureMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown()

func (*ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Marshal 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Merge 

func (dst *ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Merge(src proto.Message)

func (*ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Size 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Size() int

func (*ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal 

func (m *ConfigureMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal(b []byte) error

type ConfigureNodesMissingSchedulerResponse 

type ConfigureNodesMissingSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*ConfigureNodesMissingSchedulerResponse) Descriptor 

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

func (*ConfigureNodesMissingSchedulerResponse) ProtoMessage 

func (*ConfigureNodesMissingSchedulerResponse) ProtoMessage()

func (*ConfigureNodesMissingSchedulerResponse) Reset 

func (m *ConfigureNodesMissingSchedulerResponse) Reset()

func (*ConfigureNodesMissingSchedulerResponse) String 

func (m *ConfigureNodesMissingSchedulerResponse) String() string

func (*ConfigureNodesMissingSchedulerResponse) XXX_DiscardUnknown 

func (m *ConfigureNodesMissingSchedulerResponse) XXX_DiscardUnknown()

func (*ConfigureNodesMissingSchedulerResponse) XXX_Marshal 

func (m *ConfigureNodesMissingSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureNodesMissingSchedulerResponse) XXX_Merge 

func (dst *ConfigureNodesMissingSchedulerResponse) XXX_Merge(src proto.Message)

func (*ConfigureNodesMissingSchedulerResponse) XXX_Size 

func (m *ConfigureNodesMissingSchedulerResponse) XXX_Size() int

func (*ConfigureNodesMissingSchedulerResponse) XXX_Unmarshal 

func (m *ConfigureNodesMissingSchedulerResponse) XXX_Unmarshal(b []byte) error

type DeleteMarkedNodesRequest 

type DeleteMarkedNodesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

DeleteNodesScheduler

func (*DeleteMarkedNodesRequest) Descriptor 

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

func (*DeleteMarkedNodesRequest) ProtoMessage 

func (*DeleteMarkedNodesRequest) ProtoMessage()

func (*DeleteMarkedNodesRequest) Reset 

func (m *DeleteMarkedNodesRequest) Reset()

func (*DeleteMarkedNodesRequest) String 

func (m *DeleteMarkedNodesRequest) String() string

func (*DeleteMarkedNodesRequest) XXX_DiscardUnknown 

func (m *DeleteMarkedNodesRequest) XXX_DiscardUnknown()

func (*DeleteMarkedNodesRequest) XXX_Marshal 

func (m *DeleteMarkedNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteMarkedNodesRequest) XXX_Merge 

func (dst *DeleteMarkedNodesRequest) XXX_Merge(src proto.Message)

func (*DeleteMarkedNodesRequest) XXX_Size 

func (m *DeleteMarkedNodesRequest) XXX_Size() int

func (*DeleteMarkedNodesRequest) XXX_Unmarshal 

func (m *DeleteMarkedNodesRequest) XXX_Unmarshal(b []byte) error

type DeleteMarkedNodesResponse 

type DeleteMarkedNodesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*DeleteMarkedNodesResponse) Descriptor 

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

func (*DeleteMarkedNodesResponse) ProtoMessage 

func (*DeleteMarkedNodesResponse) ProtoMessage()

func (*DeleteMarkedNodesResponse) Reset 

func (m *DeleteMarkedNodesResponse) Reset()

func (*DeleteMarkedNodesResponse) String 

func (m *DeleteMarkedNodesResponse) String() string

func (*DeleteMarkedNodesResponse) XXX_DiscardUnknown 

func (m *DeleteMarkedNodesResponse) XXX_DiscardUnknown()

func (*DeleteMarkedNodesResponse) XXX_Marshal 

func (m *DeleteMarkedNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteMarkedNodesResponse) XXX_Merge 

func (dst *DeleteMarkedNodesResponse) XXX_Merge(src proto.Message)

func (*DeleteMarkedNodesResponse) XXX_Size 

func (m *DeleteMarkedNodesResponse) XXX_Size() int

func (*DeleteMarkedNodesResponse) XXX_Unmarshal 

func (m *DeleteMarkedNodesResponse) XXX_Unmarshal(b []byte) error

type EventHandlerClient 

type EventHandlerClient 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)
}

EventHandlerClient is the client API for EventHandler service.

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

func NewEventHandlerClient 

func NewEventHandlerClient(cc *grpc.ClientConn) EventHandlerClient

type EventHandlerServer 

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

EventHandlerServer is the server API for EventHandler service.

type Health 

type Health struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

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 

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

func (*Health) GetStatus 

func (m *Health) GetStatus() string

func (*Health) ProtoMessage 

func (*Health) ProtoMessage()

func (*Health) Reset 

func (m *Health) Reset()

func (*Health) String 

func (m *Health) String() string

func (*Health) XXX_DiscardUnknown 

func (m *Health) XXX_DiscardUnknown()

func (*Health) XXX_Marshal 

func (m *Health) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Health) XXX_Merge 

func (dst *Health) XXX_Merge(src proto.Message)

func (*Health) XXX_Size 

func (m *Health) XXX_Size() int

func (*Health) XXX_Unmarshal 

func (m *Health) XXX_Unmarshal(b []byte) error

type HealthRequest 

type HealthRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) String 

func (m *HealthRequest) String() string

func (*HealthRequest) XXX_DiscardUnknown 

func (m *HealthRequest) XXX_DiscardUnknown()

func (*HealthRequest) XXX_Marshal 

func (m *HealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthRequest) XXX_Merge 

func (dst *HealthRequest) XXX_Merge(src proto.Message)

func (*HealthRequest) XXX_Size 

func (m *HealthRequest) XXX_Size() int

func (*HealthRequest) XXX_Unmarshal 

func (m *HealthRequest) XXX_Unmarshal(b []byte) error

type IngestStatusClient 

type IngestStatusClient 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)
}

IngestStatusClient is the client API for IngestStatus service.

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

func NewIngestStatusClient 

func NewIngestStatusClient(cc *grpc.ClientConn) IngestStatusClient

type IngestStatusServer 

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

IngestStatusServer is the server API for IngestStatus 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*Job) Descriptor 

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

func (*Job) GetEvery 

func (m *Job) GetEvery() string

func (*Job) GetLastElapsed 

func (m *Job) GetLastElapsed() string

func (*Job) GetLastRun 

func (m *Job) GetLastRun() string

func (*Job) GetName 

func (m *Job) GetName() string

func (*Job) GetNextRun 

func (m *Job) GetNextRun() string

func (*Job) GetRunning 

func (m *Job) GetRunning() bool

func (*Job) GetStartedOn 

func (m *Job) GetStartedOn() string

func (*Job) GetThreshold 

func (m *Job) GetThreshold() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (dst *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

type JobSchedulerClient 

type JobSchedulerClient interface {
	StartJobScheduler(ctx context.Context, in *StartJobSchedulerRequest, opts ...grpc.CallOption) (*StartJobSchedulerResponse, error)
	StopJobScheduler(ctx context.Context, in *StopJobSchedulerRequest, opts ...grpc.CallOption) (*StopJobSchedulerResponse, error)
	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)
}

JobSchedulerClient is the client API for JobScheduler service.

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

func NewJobSchedulerClient 

func NewJobSchedulerClient(cc *grpc.ClientConn) JobSchedulerClient

type JobSchedulerServer 

type JobSchedulerServer interface {
	StartJobScheduler(context.Context, *StartJobSchedulerRequest) (*StartJobSchedulerResponse, error)
	StopJobScheduler(context.Context, *StopJobSchedulerRequest) (*StopJobSchedulerResponse, error)
	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)
}

JobSchedulerServer is the server API for JobScheduler 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*JobSchedulerStatus) Descriptor 

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

func (*JobSchedulerStatus) GetJobs 

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

func (*JobSchedulerStatus) GetRunning 

func (m *JobSchedulerStatus) GetRunning() bool

func (*JobSchedulerStatus) ProtoMessage 

func (*JobSchedulerStatus) ProtoMessage()

func (*JobSchedulerStatus) Reset 

func (m *JobSchedulerStatus) Reset()

func (*JobSchedulerStatus) String 

func (m *JobSchedulerStatus) String() string

func (*JobSchedulerStatus) XXX_DiscardUnknown 

func (m *JobSchedulerStatus) XXX_DiscardUnknown()

func (*JobSchedulerStatus) XXX_Marshal 

func (m *JobSchedulerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSchedulerStatus) XXX_Merge 

func (dst *JobSchedulerStatus) XXX_Merge(src proto.Message)

func (*JobSchedulerStatus) XXX_Size 

func (m *JobSchedulerStatus) XXX_Size() int

func (*JobSchedulerStatus) XXX_Unmarshal 

func (m *JobSchedulerStatus) XXX_Unmarshal(b []byte) error

type JobSchedulerStatusRequest 

type JobSchedulerStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*JobSchedulerStatusRequest) Descriptor 

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

func (*JobSchedulerStatusRequest) ProtoMessage 

func (*JobSchedulerStatusRequest) ProtoMessage()

func (*JobSchedulerStatusRequest) Reset 

func (m *JobSchedulerStatusRequest) Reset()

func (*JobSchedulerStatusRequest) String 

func (m *JobSchedulerStatusRequest) String() string

func (*JobSchedulerStatusRequest) XXX_DiscardUnknown 

func (m *JobSchedulerStatusRequest) XXX_DiscardUnknown()

func (*JobSchedulerStatusRequest) XXX_Marshal 

func (m *JobSchedulerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSchedulerStatusRequest) XXX_Merge 

func (dst *JobSchedulerStatusRequest) XXX_Merge(src proto.Message)

func (*JobSchedulerStatusRequest) XXX_Size 

func (m *JobSchedulerStatusRequest) XXX_Size() int

func (*JobSchedulerStatusRequest) XXX_Unmarshal 

func (m *JobSchedulerStatusRequest) XXX_Unmarshal(b []byte) error

type JobSettings 

type JobSettings struct {
	Every                string   `protobuf:"bytes,1,opt,name=every,proto3" json:"every,omitempty" toml:"every,omitempty" mapstructure:"every,omitempty"`
	Threshold            string   `` /* 133-byte string literal not displayed */
	Running              bool     `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

JobSettings - The job settings message to configure any scheduler job

func (*JobSettings) Descriptor 

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

func (*JobSettings) GetEvery 

func (m *JobSettings) GetEvery() string

func (*JobSettings) GetRunning 

func (m *JobSettings) GetRunning() bool

func (*JobSettings) GetThreshold 

func (m *JobSettings) GetThreshold() string

func (*JobSettings) ProtoMessage 

func (*JobSettings) ProtoMessage()

func (*JobSettings) Reset 

func (m *JobSettings) Reset()

func (*JobSettings) String 

func (m *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

func (*JobSettings) XXX_DiscardUnknown 

func (m *JobSettings) XXX_DiscardUnknown()

func (*JobSettings) XXX_Marshal 

func (m *JobSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSettings) XXX_Merge 

func (dst *JobSettings) XXX_Merge(src proto.Message)

func (*JobSettings) XXX_Size 

func (m *JobSettings) XXX_Size() int

func (*JobSettings) XXX_Unmarshal 

func (m *JobSettings) XXX_Unmarshal(b []byte) error

type MarkMissingNodesForDeletionRequest 

type MarkMissingNodesForDeletionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*MarkMissingNodesForDeletionRequest) Descriptor 

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

func (*MarkMissingNodesForDeletionRequest) ProtoMessage 

func (*MarkMissingNodesForDeletionRequest) ProtoMessage()

func (*MarkMissingNodesForDeletionRequest) Reset 

func (m *MarkMissingNodesForDeletionRequest) Reset()

func (*MarkMissingNodesForDeletionRequest) String 

func (m *MarkMissingNodesForDeletionRequest) String() string

func (*MarkMissingNodesForDeletionRequest) XXX_DiscardUnknown 

func (m *MarkMissingNodesForDeletionRequest) XXX_DiscardUnknown()

func (*MarkMissingNodesForDeletionRequest) XXX_Marshal 

func (m *MarkMissingNodesForDeletionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkMissingNodesForDeletionRequest) XXX_Merge 

func (dst *MarkMissingNodesForDeletionRequest) XXX_Merge(src proto.Message)

func (*MarkMissingNodesForDeletionRequest) XXX_Size 

func (m *MarkMissingNodesForDeletionRequest) XXX_Size() int

func (*MarkMissingNodesForDeletionRequest) XXX_Unmarshal 

func (m *MarkMissingNodesForDeletionRequest) XXX_Unmarshal(b []byte) error

type MarkMissingNodesForDeletionResponse 

type MarkMissingNodesForDeletionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

MissingNodesForDeletionScheduler

func (*MarkMissingNodesForDeletionResponse) Descriptor 

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

func (*MarkMissingNodesForDeletionResponse) ProtoMessage 

func (*MarkMissingNodesForDeletionResponse) ProtoMessage()

func (*MarkMissingNodesForDeletionResponse) Reset 

func (m *MarkMissingNodesForDeletionResponse) Reset()

func (*MarkMissingNodesForDeletionResponse) String 

func (m *MarkMissingNodesForDeletionResponse) String() string

func (*MarkMissingNodesForDeletionResponse) XXX_DiscardUnknown 

func (m *MarkMissingNodesForDeletionResponse) XXX_DiscardUnknown()

func (*MarkMissingNodesForDeletionResponse) XXX_Marshal 

func (m *MarkMissingNodesForDeletionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkMissingNodesForDeletionResponse) XXX_Merge 

func (dst *MarkMissingNodesForDeletionResponse) XXX_Merge(src proto.Message)

func (*MarkMissingNodesForDeletionResponse) XXX_Size 

func (m *MarkMissingNodesForDeletionResponse) XXX_Size() int

func (*MarkMissingNodesForDeletionResponse) XXX_Unmarshal 

func (m *MarkMissingNodesForDeletionResponse) XXX_Unmarshal(b []byte) error

type MarkNodesMissingRequest 

type MarkNodesMissingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

NodesMissingScheduler

func (*MarkNodesMissingRequest) Descriptor 

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

func (*MarkNodesMissingRequest) ProtoMessage 

func (*MarkNodesMissingRequest) ProtoMessage()

func (*MarkNodesMissingRequest) Reset 

func (m *MarkNodesMissingRequest) Reset()

func (*MarkNodesMissingRequest) String 

func (m *MarkNodesMissingRequest) String() string

func (*MarkNodesMissingRequest) XXX_DiscardUnknown 

func (m *MarkNodesMissingRequest) XXX_DiscardUnknown()

func (*MarkNodesMissingRequest) XXX_Marshal 

func (m *MarkNodesMissingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkNodesMissingRequest) XXX_Merge 

func (dst *MarkNodesMissingRequest) XXX_Merge(src proto.Message)

func (*MarkNodesMissingRequest) XXX_Size 

func (m *MarkNodesMissingRequest) XXX_Size() int

func (*MarkNodesMissingRequest) XXX_Unmarshal 

func (m *MarkNodesMissingRequest) XXX_Unmarshal(b []byte) error

type MarkNodesMissingResponse 

type MarkNodesMissingResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*MarkNodesMissingResponse) Descriptor 

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

func (*MarkNodesMissingResponse) ProtoMessage 

func (*MarkNodesMissingResponse) ProtoMessage()

func (*MarkNodesMissingResponse) Reset 

func (m *MarkNodesMissingResponse) Reset()

func (*MarkNodesMissingResponse) String 

func (m *MarkNodesMissingResponse) String() string

func (*MarkNodesMissingResponse) XXX_DiscardUnknown 

func (m *MarkNodesMissingResponse) XXX_DiscardUnknown()

func (*MarkNodesMissingResponse) XXX_Marshal 

func (m *MarkNodesMissingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkNodesMissingResponse) XXX_Merge 

func (dst *MarkNodesMissingResponse) XXX_Merge(src proto.Message)

func (*MarkNodesMissingResponse) XXX_Size 

func (m *MarkNodesMissingResponse) XXX_Size() int

func (*MarkNodesMissingResponse) XXX_Unmarshal 

func (m *MarkNodesMissingResponse) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}         `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte           `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32            `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

Metrics message

func (*Metrics) Descriptor 

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

func (*Metrics) GetPipeline 

func (m *Metrics) GetPipeline() *PipelineMetrics

func (*Metrics) GetUptime 

func (m *Metrics) GetUptime() float64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge 

func (dst *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type MetricsRequest 

type MetricsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*MetricsRequest) Descriptor 

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

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) Reset 

func (m *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (m *MetricsRequest) String() string

func (*MetricsRequest) XXX_DiscardUnknown 

func (m *MetricsRequest) XXX_DiscardUnknown()

func (*MetricsRequest) XXX_Marshal 

func (m *MetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsRequest) XXX_Merge 

func (dst *MetricsRequest) XXX_Merge(src proto.Message)

func (*MetricsRequest) XXX_Size 

func (m *MetricsRequest) XXX_Size() int

func (*MetricsRequest) XXX_Unmarshal 

func (m *MetricsRequest) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

Migration message

func (*MigrationStatus) Descriptor 

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

func (*MigrationStatus) GetCompleted 

func (m *MigrationStatus) GetCompleted() int64

func (*MigrationStatus) GetFinished 

func (m *MigrationStatus) GetFinished() bool

func (*MigrationStatus) GetStatus 

func (m *MigrationStatus) GetStatus() string

func (*MigrationStatus) GetTotal 

func (m *MigrationStatus) GetTotal() int64

func (*MigrationStatus) ProtoMessage 

func (*MigrationStatus) ProtoMessage()

func (*MigrationStatus) Reset 

func (m *MigrationStatus) Reset()

func (*MigrationStatus) String 

func (m *MigrationStatus) String() string

func (*MigrationStatus) XXX_DiscardUnknown 

func (m *MigrationStatus) XXX_DiscardUnknown()

func (*MigrationStatus) XXX_Marshal 

func (m *MigrationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStatus) XXX_Merge 

func (dst *MigrationStatus) XXX_Merge(src proto.Message)

func (*MigrationStatus) XXX_Size 

func (m *MigrationStatus) XXX_Size() int

func (*MigrationStatus) XXX_Unmarshal 

func (m *MigrationStatus) XXX_Unmarshal(b []byte) error

type MigrationStatusRequest 

type MigrationStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*MigrationStatusRequest) Descriptor 

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

func (*MigrationStatusRequest) ProtoMessage 

func (*MigrationStatusRequest) ProtoMessage()

func (*MigrationStatusRequest) Reset 

func (m *MigrationStatusRequest) Reset()

func (*MigrationStatusRequest) String 

func (m *MigrationStatusRequest) String() string

func (*MigrationStatusRequest) XXX_DiscardUnknown 

func (m *MigrationStatusRequest) XXX_DiscardUnknown()

func (*MigrationStatusRequest) XXX_Marshal 

func (m *MigrationStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrationStatusRequest) XXX_Merge 

func (dst *MigrationStatusRequest) XXX_Merge(src proto.Message)

func (*MigrationStatusRequest) XXX_Size 

func (m *MigrationStatusRequest) XXX_Size() int

func (*MigrationStatusRequest) XXX_Unmarshal 

func (m *MigrationStatusRequest) XXX_Unmarshal(b []byte) error

type MockChefIngesterClient 

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

MockChefIngesterClient is a mock of ChefIngesterClient interface

func NewMockChefIngesterClient 

func NewMockChefIngesterClient(ctrl *gomock.Controller) *MockChefIngesterClient

NewMockChefIngesterClient creates a new mock instance

func (*MockChefIngesterClient) EXPECT 

func (m *MockChefIngesterClient) EXPECT() *MockChefIngesterClientMockRecorder

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

func (*MockChefIngesterClient) GetVersion 

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

GetVersion mocks base method

func (*MockChefIngesterClient) ProcessChefAction 

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

ProcessChefAction mocks base method

func (*MockChefIngesterClient) ProcessChefRun 

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

ProcessChefRun mocks base method

func (*MockChefIngesterClient) ProcessLivenessPing 

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

ProcessLivenessPing mocks base method

func (*MockChefIngesterClient) ProcessMultipleNodeDeletes 

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

ProcessMultipleNodeDeletes mocks base method

func (*MockChefIngesterClient) ProcessNodeDelete 

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

ProcessNodeDelete mocks base method

type MockChefIngesterClientMockRecorder 

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

MockChefIngesterClientMockRecorder is the mock recorder for MockChefIngesterClient

func (*MockChefIngesterClientMockRecorder) GetVersion 

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

GetVersion indicates an expected call of GetVersion

func (*MockChefIngesterClientMockRecorder) ProcessChefAction 

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

ProcessChefAction indicates an expected call of ProcessChefAction

func (*MockChefIngesterClientMockRecorder) ProcessChefRun 

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

ProcessChefRun indicates an expected call of ProcessChefRun

func (*MockChefIngesterClientMockRecorder) ProcessLivenessPing 

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

ProcessLivenessPing indicates an expected call of ProcessLivenessPing

func (*MockChefIngesterClientMockRecorder) ProcessMultipleNodeDeletes 

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

ProcessMultipleNodeDeletes indicates an expected call of ProcessMultipleNodeDeletes

func (*MockChefIngesterClientMockRecorder) ProcessNodeDelete 

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

ProcessNodeDelete indicates an expected call of ProcessNodeDelete

type MockChefIngesterServer 

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

MockChefIngesterServer is a mock of ChefIngesterServer interface

func NewMockChefIngesterServer 

func NewMockChefIngesterServer(ctrl *gomock.Controller) *MockChefIngesterServer

NewMockChefIngesterServer creates a new mock instance

func (*MockChefIngesterServer) EXPECT 

func (m *MockChefIngesterServer) EXPECT() *MockChefIngesterServerMockRecorder

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

func (*MockChefIngesterServer) GetVersion 

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

GetVersion mocks base method

func (*MockChefIngesterServer) ProcessChefAction 

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

ProcessChefAction mocks base method

func (*MockChefIngesterServer) ProcessChefRun 

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

ProcessChefRun mocks base method

func (*MockChefIngesterServer) ProcessLivenessPing 

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

ProcessLivenessPing mocks base method

func (*MockChefIngesterServer) ProcessMultipleNodeDeletes 

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

ProcessMultipleNodeDeletes mocks base method

func (*MockChefIngesterServer) ProcessNodeDelete 

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

ProcessNodeDelete mocks base method

type MockChefIngesterServerMockRecorder 

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

MockChefIngesterServerMockRecorder is the mock recorder for MockChefIngesterServer

func (*MockChefIngesterServerMockRecorder) GetVersion 

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

GetVersion indicates an expected call of GetVersion

func (*MockChefIngesterServerMockRecorder) ProcessChefAction 

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

ProcessChefAction indicates an expected call of ProcessChefAction

func (*MockChefIngesterServerMockRecorder) ProcessChefRun 

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

ProcessChefRun indicates an expected call of ProcessChefRun

func (*MockChefIngesterServerMockRecorder) ProcessLivenessPing 

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

ProcessLivenessPing indicates an expected call of ProcessLivenessPing

func (*MockChefIngesterServerMockRecorder) ProcessMultipleNodeDeletes 

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

ProcessMultipleNodeDeletes indicates an expected call of ProcessMultipleNodeDeletes

func (*MockChefIngesterServerMockRecorder) ProcessNodeDelete 

func (mr *MockChefIngesterServerMockRecorder) 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PipelineMetrics) Descriptor 

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

func (*PipelineMetrics) GetTotalActionMessages 

func (m *PipelineMetrics) GetTotalActionMessages() int64

func (*PipelineMetrics) GetTotalRunMessages 

func (m *PipelineMetrics) GetTotalRunMessages() int64

func (*PipelineMetrics) ProtoMessage 

func (*PipelineMetrics) ProtoMessage()

func (*PipelineMetrics) Reset 

func (m *PipelineMetrics) Reset()

func (*PipelineMetrics) String 

func (m *PipelineMetrics) String() string

func (*PipelineMetrics) XXX_DiscardUnknown 

func (m *PipelineMetrics) XXX_DiscardUnknown()

func (*PipelineMetrics) XXX_Marshal 

func (m *PipelineMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineMetrics) XXX_Merge 

func (dst *PipelineMetrics) XXX_Merge(src proto.Message)

func (*PipelineMetrics) XXX_Size 

func (m *PipelineMetrics) XXX_Size() int

func (*PipelineMetrics) XXX_Unmarshal 

func (m *PipelineMetrics) XXX_Unmarshal(b []byte) error

type ProjectUpdateStatusReq 

type ProjectUpdateStatusReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*ProjectUpdateStatusReq) Descriptor 

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

func (*ProjectUpdateStatusReq) ProtoMessage 

func (*ProjectUpdateStatusReq) ProtoMessage()

func (*ProjectUpdateStatusReq) Reset 

func (m *ProjectUpdateStatusReq) Reset()

func (*ProjectUpdateStatusReq) String 

func (m *ProjectUpdateStatusReq) String() string

func (*ProjectUpdateStatusReq) XXX_DiscardUnknown 

func (m *ProjectUpdateStatusReq) XXX_DiscardUnknown()

func (*ProjectUpdateStatusReq) XXX_Marshal 

func (m *ProjectUpdateStatusReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProjectUpdateStatusReq) XXX_Merge 

func (dst *ProjectUpdateStatusReq) XXX_Merge(src proto.Message)

func (*ProjectUpdateStatusReq) XXX_Size 

func (m *ProjectUpdateStatusReq) XXX_Size() int

func (*ProjectUpdateStatusReq) XXX_Unmarshal 

func (m *ProjectUpdateStatusReq) XXX_Unmarshal(b []byte) error

type ProjectUpdateStatusResp 

type ProjectUpdateStatusResp struct {
	State                  string               `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty" toml:"state,omitempty" mapstructure:"state,omitempty"`
	EstimatedTimeCompelete *timestamp.Timestamp `` /* 221-byte string literal not displayed */
	PercentageComplete     float32              `` /* 199-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}             `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized       []byte               `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache          int32                `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*ProjectUpdateStatusResp) Descriptor 

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

func (*ProjectUpdateStatusResp) GetEstimatedTimeCompelete 

func (m *ProjectUpdateStatusResp) GetEstimatedTimeCompelete() *timestamp.Timestamp

func (*ProjectUpdateStatusResp) GetPercentageComplete 

func (m *ProjectUpdateStatusResp) GetPercentageComplete() float32

func (*ProjectUpdateStatusResp) GetState 

func (m *ProjectUpdateStatusResp) GetState() string

func (*ProjectUpdateStatusResp) ProtoMessage 

func (*ProjectUpdateStatusResp) ProtoMessage()

func (*ProjectUpdateStatusResp) Reset 

func (m *ProjectUpdateStatusResp) Reset()

func (*ProjectUpdateStatusResp) String 

func (m *ProjectUpdateStatusResp) String() string

func (*ProjectUpdateStatusResp) XXX_DiscardUnknown 

func (m *ProjectUpdateStatusResp) XXX_DiscardUnknown()

func (*ProjectUpdateStatusResp) XXX_Marshal 

func (m *ProjectUpdateStatusResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProjectUpdateStatusResp) XXX_Merge 

func (dst *ProjectUpdateStatusResp) XXX_Merge(src proto.Message)

func (*ProjectUpdateStatusResp) XXX_Size 

func (m *ProjectUpdateStatusResp) XXX_Size() int

func (*ProjectUpdateStatusResp) XXX_Unmarshal 

func (m *ProjectUpdateStatusResp) XXX_Unmarshal(b []byte) error

type StartDeleteNodesSchedulerRequest 

type StartDeleteNodesSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartDeleteNodesSchedulerRequest) Descriptor 

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

func (*StartDeleteNodesSchedulerRequest) ProtoMessage 

func (*StartDeleteNodesSchedulerRequest) ProtoMessage()

func (*StartDeleteNodesSchedulerRequest) Reset 

func (m *StartDeleteNodesSchedulerRequest) Reset()

func (*StartDeleteNodesSchedulerRequest) String 

func (m *StartDeleteNodesSchedulerRequest) String() string

func (*StartDeleteNodesSchedulerRequest) XXX_DiscardUnknown 

func (m *StartDeleteNodesSchedulerRequest) XXX_DiscardUnknown()

func (*StartDeleteNodesSchedulerRequest) XXX_Marshal 

func (m *StartDeleteNodesSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartDeleteNodesSchedulerRequest) XXX_Merge 

func (dst *StartDeleteNodesSchedulerRequest) XXX_Merge(src proto.Message)

func (*StartDeleteNodesSchedulerRequest) XXX_Size 

func (m *StartDeleteNodesSchedulerRequest) XXX_Size() int

func (*StartDeleteNodesSchedulerRequest) XXX_Unmarshal 

func (m *StartDeleteNodesSchedulerRequest) XXX_Unmarshal(b []byte) error

type StartDeleteNodesSchedulerResponse 

type StartDeleteNodesSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartDeleteNodesSchedulerResponse) Descriptor 

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

func (*StartDeleteNodesSchedulerResponse) ProtoMessage 

func (*StartDeleteNodesSchedulerResponse) ProtoMessage()

func (*StartDeleteNodesSchedulerResponse) Reset 

func (m *StartDeleteNodesSchedulerResponse) Reset()

func (*StartDeleteNodesSchedulerResponse) String 

func (m *StartDeleteNodesSchedulerResponse) String() string

func (*StartDeleteNodesSchedulerResponse) XXX_DiscardUnknown 

func (m *StartDeleteNodesSchedulerResponse) XXX_DiscardUnknown()

func (*StartDeleteNodesSchedulerResponse) XXX_Marshal 

func (m *StartDeleteNodesSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartDeleteNodesSchedulerResponse) XXX_Merge 

func (dst *StartDeleteNodesSchedulerResponse) XXX_Merge(src proto.Message)

func (*StartDeleteNodesSchedulerResponse) XXX_Size 

func (m *StartDeleteNodesSchedulerResponse) XXX_Size() int

func (*StartDeleteNodesSchedulerResponse) XXX_Unmarshal 

func (m *StartDeleteNodesSchedulerResponse) XXX_Unmarshal(b []byte) error

type StartJobSchedulerRequest 

type StartJobSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartJobSchedulerRequest) Descriptor 

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

func (*StartJobSchedulerRequest) ProtoMessage 

func (*StartJobSchedulerRequest) ProtoMessage()

func (*StartJobSchedulerRequest) Reset 

func (m *StartJobSchedulerRequest) Reset()

func (*StartJobSchedulerRequest) String 

func (m *StartJobSchedulerRequest) String() string

func (*StartJobSchedulerRequest) XXX_DiscardUnknown 

func (m *StartJobSchedulerRequest) XXX_DiscardUnknown()

func (*StartJobSchedulerRequest) XXX_Marshal 

func (m *StartJobSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartJobSchedulerRequest) XXX_Merge 

func (dst *StartJobSchedulerRequest) XXX_Merge(src proto.Message)

func (*StartJobSchedulerRequest) XXX_Size 

func (m *StartJobSchedulerRequest) XXX_Size() int

func (*StartJobSchedulerRequest) XXX_Unmarshal 

func (m *StartJobSchedulerRequest) XXX_Unmarshal(b []byte) error

type StartJobSchedulerResponse 

type StartJobSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartJobSchedulerResponse) Descriptor 

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

func (*StartJobSchedulerResponse) ProtoMessage 

func (*StartJobSchedulerResponse) ProtoMessage()

func (*StartJobSchedulerResponse) Reset 

func (m *StartJobSchedulerResponse) Reset()

func (*StartJobSchedulerResponse) String 

func (m *StartJobSchedulerResponse) String() string

func (*StartJobSchedulerResponse) XXX_DiscardUnknown 

func (m *StartJobSchedulerResponse) XXX_DiscardUnknown()

func (*StartJobSchedulerResponse) XXX_Marshal 

func (m *StartJobSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartJobSchedulerResponse) XXX_Merge 

func (dst *StartJobSchedulerResponse) XXX_Merge(src proto.Message)

func (*StartJobSchedulerResponse) XXX_Size 

func (m *StartJobSchedulerResponse) XXX_Size() int

func (*StartJobSchedulerResponse) XXX_Unmarshal 

func (m *StartJobSchedulerResponse) XXX_Unmarshal(b []byte) error

type StartMissingNodesForDeletionSchedulerRequest 

type StartMissingNodesForDeletionSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartMissingNodesForDeletionSchedulerRequest) Descriptor 

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

func (*StartMissingNodesForDeletionSchedulerRequest) ProtoMessage 

func (*StartMissingNodesForDeletionSchedulerRequest) ProtoMessage()

func (*StartMissingNodesForDeletionSchedulerRequest) Reset 

func (m *StartMissingNodesForDeletionSchedulerRequest) Reset()

func (*StartMissingNodesForDeletionSchedulerRequest) String 

func (m *StartMissingNodesForDeletionSchedulerRequest) String() string

func (*StartMissingNodesForDeletionSchedulerRequest) XXX_DiscardUnknown 

func (m *StartMissingNodesForDeletionSchedulerRequest) XXX_DiscardUnknown()

func (*StartMissingNodesForDeletionSchedulerRequest) XXX_Marshal 

func (m *StartMissingNodesForDeletionSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartMissingNodesForDeletionSchedulerRequest) XXX_Merge 

func (dst *StartMissingNodesForDeletionSchedulerRequest) XXX_Merge(src proto.Message)

func (*StartMissingNodesForDeletionSchedulerRequest) XXX_Size 

func (m *StartMissingNodesForDeletionSchedulerRequest) XXX_Size() int

func (*StartMissingNodesForDeletionSchedulerRequest) XXX_Unmarshal 

func (m *StartMissingNodesForDeletionSchedulerRequest) XXX_Unmarshal(b []byte) error

type StartMissingNodesForDeletionSchedulerResponse 

type StartMissingNodesForDeletionSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartMissingNodesForDeletionSchedulerResponse) Descriptor 

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

func (*StartMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*StartMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*StartMissingNodesForDeletionSchedulerResponse) Reset 

func (m *StartMissingNodesForDeletionSchedulerResponse) Reset()

func (*StartMissingNodesForDeletionSchedulerResponse) String 

func (m *StartMissingNodesForDeletionSchedulerResponse) String() string

func (*StartMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown 

func (m *StartMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown()

func (*StartMissingNodesForDeletionSchedulerResponse) XXX_Marshal 

func (m *StartMissingNodesForDeletionSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartMissingNodesForDeletionSchedulerResponse) XXX_Merge 

func (dst *StartMissingNodesForDeletionSchedulerResponse) XXX_Merge(src proto.Message)

func (*StartMissingNodesForDeletionSchedulerResponse) XXX_Size 

func (m *StartMissingNodesForDeletionSchedulerResponse) XXX_Size() int

func (*StartMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal 

func (m *StartMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal(b []byte) error

type StartNodesMissingSchedulerRequest 

type StartNodesMissingSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartNodesMissingSchedulerRequest) Descriptor 

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

func (*StartNodesMissingSchedulerRequest) ProtoMessage 

func (*StartNodesMissingSchedulerRequest) ProtoMessage()

func (*StartNodesMissingSchedulerRequest) Reset 

func (m *StartNodesMissingSchedulerRequest) Reset()

func (*StartNodesMissingSchedulerRequest) String 

func (m *StartNodesMissingSchedulerRequest) String() string

func (*StartNodesMissingSchedulerRequest) XXX_DiscardUnknown 

func (m *StartNodesMissingSchedulerRequest) XXX_DiscardUnknown()

func (*StartNodesMissingSchedulerRequest) XXX_Marshal 

func (m *StartNodesMissingSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartNodesMissingSchedulerRequest) XXX_Merge 

func (dst *StartNodesMissingSchedulerRequest) XXX_Merge(src proto.Message)

func (*StartNodesMissingSchedulerRequest) XXX_Size 

func (m *StartNodesMissingSchedulerRequest) XXX_Size() int

func (*StartNodesMissingSchedulerRequest) XXX_Unmarshal 

func (m *StartNodesMissingSchedulerRequest) XXX_Unmarshal(b []byte) error

type StartNodesMissingSchedulerResponse 

type StartNodesMissingSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StartNodesMissingSchedulerResponse) Descriptor 

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

func (*StartNodesMissingSchedulerResponse) ProtoMessage 

func (*StartNodesMissingSchedulerResponse) ProtoMessage()

func (*StartNodesMissingSchedulerResponse) Reset 

func (m *StartNodesMissingSchedulerResponse) Reset()

func (*StartNodesMissingSchedulerResponse) String 

func (m *StartNodesMissingSchedulerResponse) String() string

func (*StartNodesMissingSchedulerResponse) XXX_DiscardUnknown 

func (m *StartNodesMissingSchedulerResponse) XXX_DiscardUnknown()

func (*StartNodesMissingSchedulerResponse) XXX_Marshal 

func (m *StartNodesMissingSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartNodesMissingSchedulerResponse) XXX_Merge 

func (dst *StartNodesMissingSchedulerResponse) XXX_Merge(src proto.Message)

func (*StartNodesMissingSchedulerResponse) XXX_Size 

func (m *StartNodesMissingSchedulerResponse) XXX_Size() int

func (*StartNodesMissingSchedulerResponse) XXX_Unmarshal 

func (m *StartNodesMissingSchedulerResponse) XXX_Unmarshal(b []byte) error

type StopDeleteNodesSchedulerRequest 

type StopDeleteNodesSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopDeleteNodesSchedulerRequest) Descriptor 

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

func (*StopDeleteNodesSchedulerRequest) ProtoMessage 

func (*StopDeleteNodesSchedulerRequest) ProtoMessage()

func (*StopDeleteNodesSchedulerRequest) Reset 

func (m *StopDeleteNodesSchedulerRequest) Reset()

func (*StopDeleteNodesSchedulerRequest) String 

func (m *StopDeleteNodesSchedulerRequest) String() string

func (*StopDeleteNodesSchedulerRequest) XXX_DiscardUnknown 

func (m *StopDeleteNodesSchedulerRequest) XXX_DiscardUnknown()

func (*StopDeleteNodesSchedulerRequest) XXX_Marshal 

func (m *StopDeleteNodesSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopDeleteNodesSchedulerRequest) XXX_Merge 

func (dst *StopDeleteNodesSchedulerRequest) XXX_Merge(src proto.Message)

func (*StopDeleteNodesSchedulerRequest) XXX_Size 

func (m *StopDeleteNodesSchedulerRequest) XXX_Size() int

func (*StopDeleteNodesSchedulerRequest) XXX_Unmarshal 

func (m *StopDeleteNodesSchedulerRequest) XXX_Unmarshal(b []byte) error

type StopDeleteNodesSchedulerResponse 

type StopDeleteNodesSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopDeleteNodesSchedulerResponse) Descriptor 

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

func (*StopDeleteNodesSchedulerResponse) ProtoMessage 

func (*StopDeleteNodesSchedulerResponse) ProtoMessage()

func (*StopDeleteNodesSchedulerResponse) Reset 

func (m *StopDeleteNodesSchedulerResponse) Reset()

func (*StopDeleteNodesSchedulerResponse) String 

func (m *StopDeleteNodesSchedulerResponse) String() string

func (*StopDeleteNodesSchedulerResponse) XXX_DiscardUnknown 

func (m *StopDeleteNodesSchedulerResponse) XXX_DiscardUnknown()

func (*StopDeleteNodesSchedulerResponse) XXX_Marshal 

func (m *StopDeleteNodesSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopDeleteNodesSchedulerResponse) XXX_Merge 

func (dst *StopDeleteNodesSchedulerResponse) XXX_Merge(src proto.Message)

func (*StopDeleteNodesSchedulerResponse) XXX_Size 

func (m *StopDeleteNodesSchedulerResponse) XXX_Size() int

func (*StopDeleteNodesSchedulerResponse) XXX_Unmarshal 

func (m *StopDeleteNodesSchedulerResponse) XXX_Unmarshal(b []byte) error

type StopJobSchedulerRequest 

type StopJobSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopJobSchedulerRequest) Descriptor 

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

func (*StopJobSchedulerRequest) ProtoMessage 

func (*StopJobSchedulerRequest) ProtoMessage()

func (*StopJobSchedulerRequest) Reset 

func (m *StopJobSchedulerRequest) Reset()

func (*StopJobSchedulerRequest) String 

func (m *StopJobSchedulerRequest) String() string

func (*StopJobSchedulerRequest) XXX_DiscardUnknown 

func (m *StopJobSchedulerRequest) XXX_DiscardUnknown()

func (*StopJobSchedulerRequest) XXX_Marshal 

func (m *StopJobSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobSchedulerRequest) XXX_Merge 

func (dst *StopJobSchedulerRequest) XXX_Merge(src proto.Message)

func (*StopJobSchedulerRequest) XXX_Size 

func (m *StopJobSchedulerRequest) XXX_Size() int

func (*StopJobSchedulerRequest) XXX_Unmarshal 

func (m *StopJobSchedulerRequest) XXX_Unmarshal(b []byte) error

type StopJobSchedulerResponse 

type StopJobSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopJobSchedulerResponse) Descriptor 

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

func (*StopJobSchedulerResponse) ProtoMessage 

func (*StopJobSchedulerResponse) ProtoMessage()

func (*StopJobSchedulerResponse) Reset 

func (m *StopJobSchedulerResponse) Reset()

func (*StopJobSchedulerResponse) String 

func (m *StopJobSchedulerResponse) String() string

func (*StopJobSchedulerResponse) XXX_DiscardUnknown 

func (m *StopJobSchedulerResponse) XXX_DiscardUnknown()

func (*StopJobSchedulerResponse) XXX_Marshal 

func (m *StopJobSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobSchedulerResponse) XXX_Merge 

func (dst *StopJobSchedulerResponse) XXX_Merge(src proto.Message)

func (*StopJobSchedulerResponse) XXX_Size 

func (m *StopJobSchedulerResponse) XXX_Size() int

func (*StopJobSchedulerResponse) XXX_Unmarshal 

func (m *StopJobSchedulerResponse) XXX_Unmarshal(b []byte) error

type StopMissingNodesForDeletionSchedulerRequest 

type StopMissingNodesForDeletionSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopMissingNodesForDeletionSchedulerRequest) Descriptor 

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

func (*StopMissingNodesForDeletionSchedulerRequest) ProtoMessage 

func (*StopMissingNodesForDeletionSchedulerRequest) ProtoMessage()

func (*StopMissingNodesForDeletionSchedulerRequest) Reset 

func (m *StopMissingNodesForDeletionSchedulerRequest) Reset()

func (*StopMissingNodesForDeletionSchedulerRequest) String 

func (m *StopMissingNodesForDeletionSchedulerRequest) String() string

func (*StopMissingNodesForDeletionSchedulerRequest) XXX_DiscardUnknown 

func (m *StopMissingNodesForDeletionSchedulerRequest) XXX_DiscardUnknown()

func (*StopMissingNodesForDeletionSchedulerRequest) XXX_Marshal 

func (m *StopMissingNodesForDeletionSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopMissingNodesForDeletionSchedulerRequest) XXX_Merge 

func (dst *StopMissingNodesForDeletionSchedulerRequest) XXX_Merge(src proto.Message)

func (*StopMissingNodesForDeletionSchedulerRequest) XXX_Size 

func (m *StopMissingNodesForDeletionSchedulerRequest) XXX_Size() int

func (*StopMissingNodesForDeletionSchedulerRequest) XXX_Unmarshal 

func (m *StopMissingNodesForDeletionSchedulerRequest) XXX_Unmarshal(b []byte) error

type StopMissingNodesForDeletionSchedulerResponse 

type StopMissingNodesForDeletionSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopMissingNodesForDeletionSchedulerResponse) Descriptor 

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

func (*StopMissingNodesForDeletionSchedulerResponse) ProtoMessage 

func (*StopMissingNodesForDeletionSchedulerResponse) ProtoMessage()

func (*StopMissingNodesForDeletionSchedulerResponse) Reset 

func (m *StopMissingNodesForDeletionSchedulerResponse) Reset()

func (*StopMissingNodesForDeletionSchedulerResponse) String 

func (m *StopMissingNodesForDeletionSchedulerResponse) String() string

func (*StopMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown 

func (m *StopMissingNodesForDeletionSchedulerResponse) XXX_DiscardUnknown()

func (*StopMissingNodesForDeletionSchedulerResponse) XXX_Marshal 

func (m *StopMissingNodesForDeletionSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopMissingNodesForDeletionSchedulerResponse) XXX_Merge 

func (dst *StopMissingNodesForDeletionSchedulerResponse) XXX_Merge(src proto.Message)

func (*StopMissingNodesForDeletionSchedulerResponse) XXX_Size 

func (m *StopMissingNodesForDeletionSchedulerResponse) XXX_Size() int

func (*StopMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal 

func (m *StopMissingNodesForDeletionSchedulerResponse) XXX_Unmarshal(b []byte) error

type StopNodesMissingSchedulerRequest 

type StopNodesMissingSchedulerRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopNodesMissingSchedulerRequest) Descriptor 

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

func (*StopNodesMissingSchedulerRequest) ProtoMessage 

func (*StopNodesMissingSchedulerRequest) ProtoMessage()

func (*StopNodesMissingSchedulerRequest) Reset 

func (m *StopNodesMissingSchedulerRequest) Reset()

func (*StopNodesMissingSchedulerRequest) String 

func (m *StopNodesMissingSchedulerRequest) String() string

func (*StopNodesMissingSchedulerRequest) XXX_DiscardUnknown 

func (m *StopNodesMissingSchedulerRequest) XXX_DiscardUnknown()

func (*StopNodesMissingSchedulerRequest) XXX_Marshal 

func (m *StopNodesMissingSchedulerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopNodesMissingSchedulerRequest) XXX_Merge 

func (dst *StopNodesMissingSchedulerRequest) XXX_Merge(src proto.Message)

func (*StopNodesMissingSchedulerRequest) XXX_Size 

func (m *StopNodesMissingSchedulerRequest) XXX_Size() int

func (*StopNodesMissingSchedulerRequest) XXX_Unmarshal 

func (m *StopNodesMissingSchedulerRequest) XXX_Unmarshal(b []byte) error

type StopNodesMissingSchedulerResponse 

type StopNodesMissingSchedulerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*StopNodesMissingSchedulerResponse) Descriptor 

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

func (*StopNodesMissingSchedulerResponse) ProtoMessage 

func (*StopNodesMissingSchedulerResponse) ProtoMessage()

func (*StopNodesMissingSchedulerResponse) Reset 

func (m *StopNodesMissingSchedulerResponse) Reset()

func (*StopNodesMissingSchedulerResponse) String 

func (m *StopNodesMissingSchedulerResponse) String() string

func (*StopNodesMissingSchedulerResponse) XXX_DiscardUnknown 

func (m *StopNodesMissingSchedulerResponse) XXX_DiscardUnknown()

func (*StopNodesMissingSchedulerResponse) XXX_Marshal 

func (m *StopNodesMissingSchedulerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopNodesMissingSchedulerResponse) XXX_Merge 

func (dst *StopNodesMissingSchedulerResponse) XXX_Merge(src proto.Message)

func (*StopNodesMissingSchedulerResponse) XXX_Size 

func (m *StopNodesMissingSchedulerResponse) XXX_Size() int

func (*StopNodesMissingSchedulerResponse) XXX_Unmarshal 

func (m *StopNodesMissingSchedulerResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

Version message

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

func (*Version) Descriptor 

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

func (*Version) GetBuilt 

func (m *Version) GetBuilt() string

func (*Version) GetName 

func (m *Version) GetName() string

func (*Version) GetSha 

func (m *Version) GetSha() string

func (*Version) GetVersion 

func (m *Version) GetVersion() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) String 

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal 

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge 

func (dst *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal 

func (m *Version) XXX_Unmarshal(b []byte) error

type VersionRequest 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionRequest) XXX_Merge 

func (dst *VersionRequest) XXX_Merge(src proto.Message)

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) error

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.