hadoop_yarn

package
Version: v0.0.0-...-d973ed3 Latest Latest
Warning

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

Go to latest
Published: Feb 18, 2015 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const Default_ApplicationACLMapProto_Acl string = " "
View Source
const Default_ApplicationAttemptReportProto_Diagnostics string = "N/A"
View Source
const Default_ApplicationReportProto_Diagnostics string = "N/A"
View Source
const Default_ApplicationSubmissionContextProto_ApplicationName string = "N/A"
View Source
const Default_ApplicationSubmissionContextProto_ApplicationType string = "YARN"
View Source
const Default_ApplicationSubmissionContextProto_CancelTokensWhenComplete bool = true
View Source
const Default_ApplicationSubmissionContextProto_KeepContainersAcrossApplicationAttempts bool = false
View Source
const Default_ApplicationSubmissionContextProto_MaxAppAttempts int32 = 0
View Source
const Default_ApplicationSubmissionContextProto_Queue string = "default"
View Source
const Default_ApplicationSubmissionContextProto_UnmanagedAm bool = false
View Source
const Default_ContainerReportProto_DiagnosticsInfo string = "N/A"
View Source
const Default_ContainerStatusProto_Diagnostics string = "N/A"
View Source
const Default_ContainerStatusProto_ExitStatus int32 = -1000
View Source
const Default_FinishApplicationMasterResponseProto_IsUnregistered bool = false
View Source
const Default_KillApplicationResponseProto_IsKillCompleted bool = false
View Source
const Default_ResourceRequestProto_RelaxLocality bool = true

Variables

View Source
var AMCommandProto_name = map[int32]string{
	1: "AM_RESYNC",
	2: "AM_SHUTDOWN",
}
View Source
var AMCommandProto_value = map[string]int32{
	"AM_RESYNC":   1,
	"AM_SHUTDOWN": 2,
}
View Source
var APPLICATION_CLIENT_PROTOCOL = "org.apache.hadoop.yarn.api.ApplicationClientProtocolPB"
View Source
var APPLICATION_MASTER_PROTOCOL = "org.apache.hadoop.yarn.api.ApplicationMasterProtocolPB"
View Source
var ApplicationAccessTypeProto_name = map[int32]string{
	1: "APPACCESS_VIEW_APP",
	2: "APPACCESS_MODIFY_APP",
}
View Source
var ApplicationAccessTypeProto_value = map[string]int32{
	"APPACCESS_VIEW_APP":   1,
	"APPACCESS_MODIFY_APP": 2,
}
View Source
var ApplicationsRequestScopeProto_name = map[int32]string{
	0: "ALL",
	1: "VIEWABLE",
	2: "OWN",
}
View Source
var ApplicationsRequestScopeProto_value = map[string]int32{
	"ALL":      0,
	"VIEWABLE": 1,
	"OWN":      2,
}
View Source
var ContainerExitStatusProto_name = map[int32]string{
	0:     "SUCCESS",
	-1000: "INVALID",
	-100:  "ABORTED",
	-101:  "DISKS_FAILED",
}
View Source
var ContainerExitStatusProto_value = map[string]int32{
	"SUCCESS":      0,
	"INVALID":      -1000,
	"ABORTED":      -100,
	"DISKS_FAILED": -101,
}
View Source
var ContainerStateProto_name = map[int32]string{
	1: "C_NEW",
	2: "C_RUNNING",
	3: "C_COMPLETE",
}
View Source
var ContainerStateProto_value = map[string]int32{
	"C_NEW":      1,
	"C_RUNNING":  2,
	"C_COMPLETE": 3,
}
View Source
var FinalApplicationStatusProto_name = map[int32]string{
	0: "APP_UNDEFINED",
	1: "APP_SUCCEEDED",
	2: "APP_FAILED",
	3: "APP_KILLED",
}
View Source
var FinalApplicationStatusProto_value = map[string]int32{
	"APP_UNDEFINED": 0,
	"APP_SUCCEEDED": 1,
	"APP_FAILED":    2,
	"APP_KILLED":    3,
}
View Source
var LocalResourceTypeProto_name = map[int32]string{
	1: "ARCHIVE",
	2: "FILE",
	3: "PATTERN",
}
View Source
var LocalResourceTypeProto_value = map[string]int32{
	"ARCHIVE": 1,
	"FILE":    2,
	"PATTERN": 3,
}
View Source
var LocalResourceVisibilityProto_name = map[int32]string{
	1: "PUBLIC",
	2: "PRIVATE",
	3: "APPLICATION",
}
View Source
var LocalResourceVisibilityProto_value = map[string]int32{
	"PUBLIC":      1,
	"PRIVATE":     2,
	"APPLICATION": 3,
}
View Source
var NodeStateProto_name = map[int32]string{
	1: "NS_NEW",
	2: "NS_RUNNING",
	3: "NS_UNHEALTHY",
	4: "NS_DECOMMISSIONED",
	5: "NS_LOST",
	6: "NS_REBOOTED",
}
View Source
var NodeStateProto_value = map[string]int32{
	"NS_NEW":            1,
	"NS_RUNNING":        2,
	"NS_UNHEALTHY":      3,
	"NS_DECOMMISSIONED": 4,
	"NS_LOST":           5,
	"NS_REBOOTED":       6,
}
View Source
var QueueACLProto_name = map[int32]string{
	1: "QACL_SUBMIT_APPLICATIONS",
	2: "QACL_ADMINISTER_QUEUE",
}
View Source
var QueueACLProto_value = map[string]int32{
	"QACL_SUBMIT_APPLICATIONS": 1,
	"QACL_ADMINISTER_QUEUE":    2,
}
View Source
var QueueStateProto_name = map[int32]string{
	1: "Q_STOPPED",
	2: "Q_RUNNING",
}
View Source
var QueueStateProto_value = map[string]int32{
	"Q_STOPPED": 1,
	"Q_RUNNING": 2,
}
View Source
var YarnApplicationAttemptStateProto_name = map[int32]string{
	1:  "APP_ATTEMPT_NEW",
	2:  "APP_ATTEMPT_SUBMITTED",
	3:  "APP_ATTEMPT_SCHEDULED",
	4:  "APP_ATTEMPT_ALLOCATED_SAVING",
	5:  "APP_ATTEMPT_ALLOCATED",
	6:  "APP_ATTEMPT_LAUNCHED",
	7:  "APP_ATTEMPT_FAILED",
	8:  "APP_ATTEMPT_RUNNING",
	9:  "APP_ATTEMPT_FINISHING",
	10: "APP_ATTEMPT_FINISHED",
	11: "APP_ATTEMPT_KILLED",
}
View Source
var YarnApplicationAttemptStateProto_value = map[string]int32{
	"APP_ATTEMPT_NEW":              1,
	"APP_ATTEMPT_SUBMITTED":        2,
	"APP_ATTEMPT_SCHEDULED":        3,
	"APP_ATTEMPT_ALLOCATED_SAVING": 4,
	"APP_ATTEMPT_ALLOCATED":        5,
	"APP_ATTEMPT_LAUNCHED":         6,
	"APP_ATTEMPT_FAILED":           7,
	"APP_ATTEMPT_RUNNING":          8,
	"APP_ATTEMPT_FINISHING":        9,
	"APP_ATTEMPT_FINISHED":         10,
	"APP_ATTEMPT_KILLED":           11,
}
View Source
var YarnApplicationStateProto_name = map[int32]string{
	1: "NEW",
	2: "NEW_SAVING",
	3: "SUBMITTED",
	4: "ACCEPTED",
	5: "RUNNING",
	6: "FINISHED",
	7: "FAILED",
	8: "KILLED",
}
View Source
var YarnApplicationStateProto_value = map[string]int32{
	"NEW":        1,
	"NEW_SAVING": 2,
	"SUBMITTED":  3,
	"ACCEPTED":   4,
	"RUNNING":    5,
	"FINISHED":   6,
	"FAILED":     7,
	"KILLED":     8,
}

Functions

This section is empty.

Types

type AMCommandProto

type AMCommandProto int32
const (
	AMCommandProto_AM_RESYNC   AMCommandProto = 1
	AMCommandProto_AM_SHUTDOWN AMCommandProto = 2
)

func (AMCommandProto) Enum

func (x AMCommandProto) Enum() *AMCommandProto

func (AMCommandProto) MarshalJSON

func (x AMCommandProto) MarshalJSON() ([]byte, error)

func (AMCommandProto) String

func (x AMCommandProto) String() string

func (*AMCommandProto) UnmarshalJSON

func (x *AMCommandProto) UnmarshalJSON(data []byte) error

type AllocateRequestProto

type AllocateRequestProto struct {
	Ask              []*ResourceRequestProto                  `protobuf:"bytes,1,rep,name=ask" json:"ask,omitempty"`
	Release          []*ContainerIdProto                      `protobuf:"bytes,2,rep,name=release" json:"release,omitempty"`
	BlacklistRequest *ResourceBlacklistRequestProto           `protobuf:"bytes,3,opt,name=blacklist_request" json:"blacklist_request,omitempty"`
	ResponseId       *int32                                   `protobuf:"varint,4,opt,name=response_id" json:"response_id,omitempty"`
	Progress         *float32                                 `protobuf:"fixed32,5,opt,name=progress" json:"progress,omitempty"`
	IncreaseRequest  []*ContainerResourceIncreaseRequestProto `protobuf:"bytes,6,rep,name=increase_request" json:"increase_request,omitempty"`
	XXX_unrecognized []byte                                   `json:"-"`
}

func (*AllocateRequestProto) GetAsk

func (*AllocateRequestProto) GetBlacklistRequest

func (m *AllocateRequestProto) GetBlacklistRequest() *ResourceBlacklistRequestProto

func (*AllocateRequestProto) GetIncreaseRequest

func (*AllocateRequestProto) GetProgress

func (m *AllocateRequestProto) GetProgress() float32

func (*AllocateRequestProto) GetRelease

func (m *AllocateRequestProto) GetRelease() []*ContainerIdProto

func (*AllocateRequestProto) GetResponseId

func (m *AllocateRequestProto) GetResponseId() int32

func (*AllocateRequestProto) ProtoMessage

func (*AllocateRequestProto) ProtoMessage()

func (*AllocateRequestProto) Reset

func (m *AllocateRequestProto) Reset()

func (*AllocateRequestProto) String

func (m *AllocateRequestProto) String() string

type AllocateResponseProto

type AllocateResponseProto struct {
	AMCommand                  *AMCommandProto                   `protobuf:"varint,1,opt,name=a_m_command,enum=hadoop.yarn.AMCommandProto" json:"a_m_command,omitempty"`
	ResponseId                 *int32                            `protobuf:"varint,2,opt,name=response_id" json:"response_id,omitempty"`
	AllocatedContainers        []*ContainerProto                 `protobuf:"bytes,3,rep,name=allocated_containers" json:"allocated_containers,omitempty"`
	CompletedContainerStatuses []*ContainerStatusProto           `protobuf:"bytes,4,rep,name=completed_container_statuses" json:"completed_container_statuses,omitempty"`
	Limit                      *ResourceProto                    `protobuf:"bytes,5,opt,name=limit" json:"limit,omitempty"`
	UpdatedNodes               []*NodeReportProto                `protobuf:"bytes,6,rep,name=updated_nodes" json:"updated_nodes,omitempty"`
	NumClusterNodes            *int32                            `protobuf:"varint,7,opt,name=num_cluster_nodes" json:"num_cluster_nodes,omitempty"`
	Preempt                    *PreemptionMessageProto           `protobuf:"bytes,8,opt,name=preempt" json:"preempt,omitempty"`
	NmTokens                   []*NMTokenProto                   `protobuf:"bytes,9,rep,name=nm_tokens" json:"nm_tokens,omitempty"`
	IncreasedContainers        []*ContainerResourceIncreaseProto `protobuf:"bytes,10,rep,name=increased_containers" json:"increased_containers,omitempty"`
	DecreasedContainers        []*ContainerResourceDecreaseProto `protobuf:"bytes,11,rep,name=decreased_containers" json:"decreased_containers,omitempty"`
	AmRmToken                  *hadoop_common.TokenProto         `protobuf:"bytes,12,opt,name=am_rm_token" json:"am_rm_token,omitempty"`
	XXX_unrecognized           []byte                            `json:"-"`
}

func (*AllocateResponseProto) GetAMCommand

func (m *AllocateResponseProto) GetAMCommand() AMCommandProto

func (*AllocateResponseProto) GetAllocatedContainers

func (m *AllocateResponseProto) GetAllocatedContainers() []*ContainerProto

func (*AllocateResponseProto) GetAmRmToken

func (m *AllocateResponseProto) GetAmRmToken() *hadoop_common.TokenProto

func (*AllocateResponseProto) GetCompletedContainerStatuses

func (m *AllocateResponseProto) GetCompletedContainerStatuses() []*ContainerStatusProto

func (*AllocateResponseProto) GetDecreasedContainers

func (m *AllocateResponseProto) GetDecreasedContainers() []*ContainerResourceDecreaseProto

func (*AllocateResponseProto) GetIncreasedContainers

func (m *AllocateResponseProto) GetIncreasedContainers() []*ContainerResourceIncreaseProto

func (*AllocateResponseProto) GetLimit

func (m *AllocateResponseProto) GetLimit() *ResourceProto

func (*AllocateResponseProto) GetNmTokens

func (m *AllocateResponseProto) GetNmTokens() []*NMTokenProto

func (*AllocateResponseProto) GetNumClusterNodes

func (m *AllocateResponseProto) GetNumClusterNodes() int32

func (*AllocateResponseProto) GetPreempt

func (*AllocateResponseProto) GetResponseId

func (m *AllocateResponseProto) GetResponseId() int32

func (*AllocateResponseProto) GetUpdatedNodes

func (m *AllocateResponseProto) GetUpdatedNodes() []*NodeReportProto

func (*AllocateResponseProto) ProtoMessage

func (*AllocateResponseProto) ProtoMessage()

func (*AllocateResponseProto) Reset

func (m *AllocateResponseProto) Reset()

func (*AllocateResponseProto) String

func (m *AllocateResponseProto) String() string

type ApplicationACLMapProto

type ApplicationACLMapProto struct {
	AccessType       *ApplicationAccessTypeProto `protobuf:"varint,1,opt,name=accessType,enum=hadoop.yarn.ApplicationAccessTypeProto" json:"accessType,omitempty"`
	Acl              *string                     `protobuf:"bytes,2,opt,name=acl,def= " json:"acl,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*ApplicationACLMapProto) GetAccessType

func (*ApplicationACLMapProto) GetAcl

func (m *ApplicationACLMapProto) GetAcl() string

func (*ApplicationACLMapProto) ProtoMessage

func (*ApplicationACLMapProto) ProtoMessage()

func (*ApplicationACLMapProto) Reset

func (m *ApplicationACLMapProto) Reset()

func (*ApplicationACLMapProto) String

func (m *ApplicationACLMapProto) String() string

type ApplicationAccessTypeProto

type ApplicationAccessTypeProto int32
const (
	ApplicationAccessTypeProto_APPACCESS_VIEW_APP   ApplicationAccessTypeProto = 1
	ApplicationAccessTypeProto_APPACCESS_MODIFY_APP ApplicationAccessTypeProto = 2
)

func (ApplicationAccessTypeProto) Enum

func (ApplicationAccessTypeProto) MarshalJSON

func (x ApplicationAccessTypeProto) MarshalJSON() ([]byte, error)

func (ApplicationAccessTypeProto) String

func (*ApplicationAccessTypeProto) UnmarshalJSON

func (x *ApplicationAccessTypeProto) UnmarshalJSON(data []byte) error

type ApplicationAttemptIdProto

type ApplicationAttemptIdProto struct {
	ApplicationId    *ApplicationIdProto `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	AttemptId        *int32              `protobuf:"varint,2,opt,name=attemptId" json:"attemptId,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*ApplicationAttemptIdProto) GetApplicationId

func (m *ApplicationAttemptIdProto) GetApplicationId() *ApplicationIdProto

func (*ApplicationAttemptIdProto) GetAttemptId

func (m *ApplicationAttemptIdProto) GetAttemptId() int32

func (*ApplicationAttemptIdProto) ProtoMessage

func (*ApplicationAttemptIdProto) ProtoMessage()

func (*ApplicationAttemptIdProto) Reset

func (m *ApplicationAttemptIdProto) Reset()

func (*ApplicationAttemptIdProto) String

func (m *ApplicationAttemptIdProto) String() string

type ApplicationAttemptReportProto

type ApplicationAttemptReportProto struct {
	ApplicationAttemptId        *ApplicationAttemptIdProto        `protobuf:"bytes,1,opt,name=application_attempt_id" json:"application_attempt_id,omitempty"`
	Host                        *string                           `protobuf:"bytes,2,opt,name=host" json:"host,omitempty"`
	RpcPort                     *int32                            `protobuf:"varint,3,opt,name=rpc_port" json:"rpc_port,omitempty"`
	TrackingUrl                 *string                           `protobuf:"bytes,4,opt,name=tracking_url" json:"tracking_url,omitempty"`
	Diagnostics                 *string                           `protobuf:"bytes,5,opt,name=diagnostics,def=N/A" json:"diagnostics,omitempty"`
	YarnApplicationAttemptState *YarnApplicationAttemptStateProto `` /* 157-byte string literal not displayed */
	AmContainerId               *ContainerIdProto                 `protobuf:"bytes,7,opt,name=am_container_id" json:"am_container_id,omitempty"`
	XXX_unrecognized            []byte                            `json:"-"`
}

func (*ApplicationAttemptReportProto) GetAmContainerId

func (m *ApplicationAttemptReportProto) GetAmContainerId() *ContainerIdProto

func (*ApplicationAttemptReportProto) GetApplicationAttemptId

func (m *ApplicationAttemptReportProto) GetApplicationAttemptId() *ApplicationAttemptIdProto

func (*ApplicationAttemptReportProto) GetDiagnostics

func (m *ApplicationAttemptReportProto) GetDiagnostics() string

func (*ApplicationAttemptReportProto) GetHost

func (*ApplicationAttemptReportProto) GetRpcPort

func (m *ApplicationAttemptReportProto) GetRpcPort() int32

func (*ApplicationAttemptReportProto) GetTrackingUrl

func (m *ApplicationAttemptReportProto) GetTrackingUrl() string

func (*ApplicationAttemptReportProto) GetYarnApplicationAttemptState

func (m *ApplicationAttemptReportProto) GetYarnApplicationAttemptState() YarnApplicationAttemptStateProto

func (*ApplicationAttemptReportProto) ProtoMessage

func (*ApplicationAttemptReportProto) ProtoMessage()

func (*ApplicationAttemptReportProto) Reset

func (m *ApplicationAttemptReportProto) Reset()

func (*ApplicationAttemptReportProto) String

type ApplicationClientProtocolService

func DialApplicationClientProtocolService

func DialApplicationClientProtocolService(conf yarn_conf.YarnConfiguration) (ApplicationClientProtocolService, error)

DialApplicationClientProtocolService connects to an ApplicationClientProtocolService at the specified network address.

type ApplicationClientProtocolServiceClient

type ApplicationClientProtocolServiceClient struct {
	*hadoop_ipc_client.Client
}

func (*ApplicationClientProtocolServiceClient) ForceKillApplication

func (*ApplicationClientProtocolServiceClient) GetApplicationAttemptReport

func (*ApplicationClientProtocolServiceClient) GetApplicationReport

func (*ApplicationClientProtocolServiceClient) GetApplications

func (*ApplicationClientProtocolServiceClient) GetClusterMetrics

func (*ApplicationClientProtocolServiceClient) GetClusterNodes

func (*ApplicationClientProtocolServiceClient) GetNewApplication

func (*ApplicationClientProtocolServiceClient) GetQueueInfo

func (*ApplicationClientProtocolServiceClient) GetQueueUserAcls

func (*ApplicationClientProtocolServiceClient) SubmitApplication

type ApplicationIdProto

type ApplicationIdProto struct {
	Id               *int32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	ClusterTimestamp *int64 `protobuf:"varint,2,opt,name=cluster_timestamp" json:"cluster_timestamp,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ApplicationIdProto) GetClusterTimestamp

func (m *ApplicationIdProto) GetClusterTimestamp() int64

func (*ApplicationIdProto) GetId

func (m *ApplicationIdProto) GetId() int32

func (*ApplicationIdProto) ProtoMessage

func (*ApplicationIdProto) ProtoMessage()

func (*ApplicationIdProto) Reset

func (m *ApplicationIdProto) Reset()

func (*ApplicationIdProto) String

func (m *ApplicationIdProto) String() string

type ApplicationMasterProtocolServiceClient

type ApplicationMasterProtocolServiceClient struct {
	*hadoop_ipc_client.Client
}

func (*ApplicationMasterProtocolServiceClient) Allocate

func (*ApplicationMasterProtocolServiceClient) FinishApplicationMaster

func (*ApplicationMasterProtocolServiceClient) RegisterApplicationMaster

type ApplicationReportProto

type ApplicationReportProto struct {
	ApplicationId               *ApplicationIdProto                  `protobuf:"bytes,1,opt,name=applicationId" json:"applicationId,omitempty"`
	User                        *string                              `protobuf:"bytes,2,opt,name=user" json:"user,omitempty"`
	Queue                       *string                              `protobuf:"bytes,3,opt,name=queue" json:"queue,omitempty"`
	Name                        *string                              `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	Host                        *string                              `protobuf:"bytes,5,opt,name=host" json:"host,omitempty"`
	RpcPort                     *int32                               `protobuf:"varint,6,opt,name=rpc_port" json:"rpc_port,omitempty"`
	ClientToAmToken             *hadoop_common.TokenProto            `protobuf:"bytes,7,opt,name=client_to_am_token" json:"client_to_am_token,omitempty"`
	YarnApplicationState        *YarnApplicationStateProto           `` /* 134-byte string literal not displayed */
	TrackingUrl                 *string                              `protobuf:"bytes,9,opt,name=trackingUrl" json:"trackingUrl,omitempty"`
	Diagnostics                 *string                              `protobuf:"bytes,10,opt,name=diagnostics,def=N/A" json:"diagnostics,omitempty"`
	StartTime                   *int64                               `protobuf:"varint,11,opt,name=startTime" json:"startTime,omitempty"`
	FinishTime                  *int64                               `protobuf:"varint,12,opt,name=finishTime" json:"finishTime,omitempty"`
	FinalApplicationStatus      *FinalApplicationStatusProto         `` /* 141-byte string literal not displayed */
	AppResource_Usage           *ApplicationResourceUsageReportProto `protobuf:"bytes,14,opt,name=app_resource_Usage" json:"app_resource_Usage,omitempty"`
	OriginalTrackingUrl         *string                              `protobuf:"bytes,15,opt,name=originalTrackingUrl" json:"originalTrackingUrl,omitempty"`
	CurrentApplicationAttemptId *ApplicationAttemptIdProto           `protobuf:"bytes,16,opt,name=currentApplicationAttemptId" json:"currentApplicationAttemptId,omitempty"`
	Progress                    *float32                             `protobuf:"fixed32,17,opt,name=progress" json:"progress,omitempty"`
	ApplicationType             *string                              `protobuf:"bytes,18,opt,name=applicationType" json:"applicationType,omitempty"`
	AmRmToken                   *hadoop_common.TokenProto            `protobuf:"bytes,19,opt,name=am_rm_token" json:"am_rm_token,omitempty"`
	ApplicationTags             []string                             `protobuf:"bytes,20,rep,name=applicationTags" json:"applicationTags,omitempty"`
	XXX_unrecognized            []byte                               `json:"-"`
}

func (*ApplicationReportProto) GetAmRmToken

func (m *ApplicationReportProto) GetAmRmToken() *hadoop_common.TokenProto

func (*ApplicationReportProto) GetAppResource_Usage

func (*ApplicationReportProto) GetApplicationId

func (m *ApplicationReportProto) GetApplicationId() *ApplicationIdProto

func (*ApplicationReportProto) GetApplicationTags

func (m *ApplicationReportProto) GetApplicationTags() []string

func (*ApplicationReportProto) GetApplicationType

func (m *ApplicationReportProto) GetApplicationType() string

func (*ApplicationReportProto) GetClientToAmToken

func (m *ApplicationReportProto) GetClientToAmToken() *hadoop_common.TokenProto

func (*ApplicationReportProto) GetCurrentApplicationAttemptId

func (m *ApplicationReportProto) GetCurrentApplicationAttemptId() *ApplicationAttemptIdProto

func (*ApplicationReportProto) GetDiagnostics

func (m *ApplicationReportProto) GetDiagnostics() string

func (*ApplicationReportProto) GetFinalApplicationStatus

func (m *ApplicationReportProto) GetFinalApplicationStatus() FinalApplicationStatusProto

func (*ApplicationReportProto) GetFinishTime

func (m *ApplicationReportProto) GetFinishTime() int64

func (*ApplicationReportProto) GetHost

func (m *ApplicationReportProto) GetHost() string

func (*ApplicationReportProto) GetName

func (m *ApplicationReportProto) GetName() string

func (*ApplicationReportProto) GetOriginalTrackingUrl

func (m *ApplicationReportProto) GetOriginalTrackingUrl() string

func (*ApplicationReportProto) GetProgress

func (m *ApplicationReportProto) GetProgress() float32

func (*ApplicationReportProto) GetQueue

func (m *ApplicationReportProto) GetQueue() string

func (*ApplicationReportProto) GetRpcPort

func (m *ApplicationReportProto) GetRpcPort() int32

func (*ApplicationReportProto) GetStartTime

func (m *ApplicationReportProto) GetStartTime() int64

func (*ApplicationReportProto) GetTrackingUrl

func (m *ApplicationReportProto) GetTrackingUrl() string

func (*ApplicationReportProto) GetUser

func (m *ApplicationReportProto) GetUser() string

func (*ApplicationReportProto) GetYarnApplicationState

func (m *ApplicationReportProto) GetYarnApplicationState() YarnApplicationStateProto

func (*ApplicationReportProto) ProtoMessage

func (*ApplicationReportProto) ProtoMessage()

func (*ApplicationReportProto) Reset

func (m *ApplicationReportProto) Reset()

func (*ApplicationReportProto) String

func (m *ApplicationReportProto) String() string

type ApplicationResourceUsageReportProto

type ApplicationResourceUsageReportProto struct {
	NumUsedContainers     *int32         `protobuf:"varint,1,opt,name=num_used_containers" json:"num_used_containers,omitempty"`
	NumReservedContainers *int32         `protobuf:"varint,2,opt,name=num_reserved_containers" json:"num_reserved_containers,omitempty"`
	UsedResources         *ResourceProto `protobuf:"bytes,3,opt,name=used_resources" json:"used_resources,omitempty"`
	ReservedResources     *ResourceProto `protobuf:"bytes,4,opt,name=reserved_resources" json:"reserved_resources,omitempty"`
	NeededResources       *ResourceProto `protobuf:"bytes,5,opt,name=needed_resources" json:"needed_resources,omitempty"`
	XXX_unrecognized      []byte         `json:"-"`
}

func (*ApplicationResourceUsageReportProto) GetNeededResources

func (m *ApplicationResourceUsageReportProto) GetNeededResources() *ResourceProto

func (*ApplicationResourceUsageReportProto) GetNumReservedContainers

func (m *ApplicationResourceUsageReportProto) GetNumReservedContainers() int32

func (*ApplicationResourceUsageReportProto) GetNumUsedContainers

func (m *ApplicationResourceUsageReportProto) GetNumUsedContainers() int32

func (*ApplicationResourceUsageReportProto) GetReservedResources

func (m *ApplicationResourceUsageReportProto) GetReservedResources() *ResourceProto

func (*ApplicationResourceUsageReportProto) GetUsedResources

func (m *ApplicationResourceUsageReportProto) GetUsedResources() *ResourceProto

func (*ApplicationResourceUsageReportProto) ProtoMessage

func (*ApplicationResourceUsageReportProto) ProtoMessage()

func (*ApplicationResourceUsageReportProto) Reset

func (*ApplicationResourceUsageReportProto) String

type ApplicationSubmissionContextProto

type ApplicationSubmissionContextProto struct {
	ApplicationId                           *ApplicationIdProto          `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	ApplicationName                         *string                      `protobuf:"bytes,2,opt,name=application_name,def=N/A" json:"application_name,omitempty"`
	Queue                                   *string                      `protobuf:"bytes,3,opt,name=queue,def=default" json:"queue,omitempty"`
	Priority                                *PriorityProto               `protobuf:"bytes,4,opt,name=priority" json:"priority,omitempty"`
	AmContainerSpec                         *ContainerLaunchContextProto `protobuf:"bytes,5,opt,name=am_container_spec" json:"am_container_spec,omitempty"`
	CancelTokensWhenComplete                *bool                        `protobuf:"varint,6,opt,name=cancel_tokens_when_complete,def=1" json:"cancel_tokens_when_complete,omitempty"`
	UnmanagedAm                             *bool                        `protobuf:"varint,7,opt,name=unmanaged_am,def=0" json:"unmanaged_am,omitempty"`
	MaxAppAttempts                          *int32                       `protobuf:"varint,8,opt,name=maxAppAttempts,def=0" json:"maxAppAttempts,omitempty"`
	Resource                                *ResourceProto               `protobuf:"bytes,9,opt,name=resource" json:"resource,omitempty"`
	ApplicationType                         *string                      `protobuf:"bytes,10,opt,name=applicationType,def=YARN" json:"applicationType,omitempty"`
	KeepContainersAcrossApplicationAttempts *bool                        `` /* 140-byte string literal not displayed */
	ApplicationTags                         []string                     `protobuf:"bytes,12,rep,name=applicationTags" json:"applicationTags,omitempty"`
	XXX_unrecognized                        []byte                       `json:"-"`
}

////////////////////////////////////////////////////////////////////// //// From client_RM_Protocol ///////////////////////////////////////// //////////////////////////////////////////////////////////////////////

func (*ApplicationSubmissionContextProto) GetAmContainerSpec

func (*ApplicationSubmissionContextProto) GetApplicationId

func (*ApplicationSubmissionContextProto) GetApplicationName

func (m *ApplicationSubmissionContextProto) GetApplicationName() string

func (*ApplicationSubmissionContextProto) GetApplicationTags

func (m *ApplicationSubmissionContextProto) GetApplicationTags() []string

func (*ApplicationSubmissionContextProto) GetApplicationType

func (m *ApplicationSubmissionContextProto) GetApplicationType() string

func (*ApplicationSubmissionContextProto) GetCancelTokensWhenComplete

func (m *ApplicationSubmissionContextProto) GetCancelTokensWhenComplete() bool

func (*ApplicationSubmissionContextProto) GetKeepContainersAcrossApplicationAttempts

func (m *ApplicationSubmissionContextProto) GetKeepContainersAcrossApplicationAttempts() bool

func (*ApplicationSubmissionContextProto) GetMaxAppAttempts

func (m *ApplicationSubmissionContextProto) GetMaxAppAttempts() int32

func (*ApplicationSubmissionContextProto) GetPriority

func (*ApplicationSubmissionContextProto) GetQueue

func (*ApplicationSubmissionContextProto) GetResource

func (*ApplicationSubmissionContextProto) GetUnmanagedAm

func (m *ApplicationSubmissionContextProto) GetUnmanagedAm() bool

func (*ApplicationSubmissionContextProto) ProtoMessage

func (*ApplicationSubmissionContextProto) ProtoMessage()

func (*ApplicationSubmissionContextProto) Reset

func (*ApplicationSubmissionContextProto) String

type ApplicationsRequestScopeProto

type ApplicationsRequestScopeProto int32
const (
	ApplicationsRequestScopeProto_ALL      ApplicationsRequestScopeProto = 0
	ApplicationsRequestScopeProto_VIEWABLE ApplicationsRequestScopeProto = 1
	ApplicationsRequestScopeProto_OWN      ApplicationsRequestScopeProto = 2
)
const Default_GetApplicationsRequestProto_Scope ApplicationsRequestScopeProto = ApplicationsRequestScopeProto_ALL

func (ApplicationsRequestScopeProto) Enum

func (ApplicationsRequestScopeProto) MarshalJSON

func (x ApplicationsRequestScopeProto) MarshalJSON() ([]byte, error)

func (ApplicationsRequestScopeProto) String

func (*ApplicationsRequestScopeProto) UnmarshalJSON

func (x *ApplicationsRequestScopeProto) UnmarshalJSON(data []byte) error

type ContainerExceptionMapProto

type ContainerExceptionMapProto struct {
	ContainerId      *ContainerIdProto         `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	Exception        *SerializedExceptionProto `protobuf:"bytes,2,opt,name=exception" json:"exception,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ContainerExceptionMapProto) GetContainerId

func (m *ContainerExceptionMapProto) GetContainerId() *ContainerIdProto

func (*ContainerExceptionMapProto) GetException

func (*ContainerExceptionMapProto) ProtoMessage

func (*ContainerExceptionMapProto) ProtoMessage()

func (*ContainerExceptionMapProto) Reset

func (m *ContainerExceptionMapProto) Reset()

func (*ContainerExceptionMapProto) String

func (m *ContainerExceptionMapProto) String() string

type ContainerExitStatusProto

type ContainerExitStatusProto int32
const (
	ContainerExitStatusProto_SUCCESS      ContainerExitStatusProto = 0
	ContainerExitStatusProto_INVALID      ContainerExitStatusProto = -1000
	ContainerExitStatusProto_ABORTED      ContainerExitStatusProto = -100
	ContainerExitStatusProto_DISKS_FAILED ContainerExitStatusProto = -101
)

func (ContainerExitStatusProto) Enum

func (ContainerExitStatusProto) MarshalJSON

func (x ContainerExitStatusProto) MarshalJSON() ([]byte, error)

func (ContainerExitStatusProto) String

func (x ContainerExitStatusProto) String() string

func (*ContainerExitStatusProto) UnmarshalJSON

func (x *ContainerExitStatusProto) UnmarshalJSON(data []byte) error

type ContainerIdProto

type ContainerIdProto struct {
	AppId            *ApplicationIdProto        `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	AppAttemptId     *ApplicationAttemptIdProto `protobuf:"bytes,2,opt,name=app_attempt_id" json:"app_attempt_id,omitempty"`
	Id               *int32                     `protobuf:"varint,3,opt,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*ContainerIdProto) GetAppAttemptId

func (m *ContainerIdProto) GetAppAttemptId() *ApplicationAttemptIdProto

func (*ContainerIdProto) GetAppId

func (m *ContainerIdProto) GetAppId() *ApplicationIdProto

func (*ContainerIdProto) GetId

func (m *ContainerIdProto) GetId() int32

func (*ContainerIdProto) ProtoMessage

func (*ContainerIdProto) ProtoMessage()

func (*ContainerIdProto) Reset

func (m *ContainerIdProto) Reset()

func (*ContainerIdProto) String

func (m *ContainerIdProto) String() string

type ContainerLaunchContextProto

type ContainerLaunchContextProto struct {
	LocalResources   []*StringLocalResourceMapProto `protobuf:"bytes,1,rep,name=localResources" json:"localResources,omitempty"`
	Tokens           []byte                         `protobuf:"bytes,2,opt,name=tokens" json:"tokens,omitempty"`
	ServiceData      []*StringBytesMapProto         `protobuf:"bytes,3,rep,name=service_data" json:"service_data,omitempty"`
	Environment      []*StringStringMapProto        `protobuf:"bytes,4,rep,name=environment" json:"environment,omitempty"`
	Command          []string                       `protobuf:"bytes,5,rep,name=command" json:"command,omitempty"`
	Application_ACLs []*ApplicationACLMapProto      `protobuf:"bytes,6,rep,name=application_ACLs" json:"application_ACLs,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func (*ContainerLaunchContextProto) GetApplication_ACLs

func (m *ContainerLaunchContextProto) GetApplication_ACLs() []*ApplicationACLMapProto

func (*ContainerLaunchContextProto) GetCommand

func (m *ContainerLaunchContextProto) GetCommand() []string

func (*ContainerLaunchContextProto) GetEnvironment

func (m *ContainerLaunchContextProto) GetEnvironment() []*StringStringMapProto

func (*ContainerLaunchContextProto) GetLocalResources

func (m *ContainerLaunchContextProto) GetLocalResources() []*StringLocalResourceMapProto

func (*ContainerLaunchContextProto) GetServiceData

func (m *ContainerLaunchContextProto) GetServiceData() []*StringBytesMapProto

func (*ContainerLaunchContextProto) GetTokens

func (m *ContainerLaunchContextProto) GetTokens() []byte

func (*ContainerLaunchContextProto) ProtoMessage

func (*ContainerLaunchContextProto) ProtoMessage()

func (*ContainerLaunchContextProto) Reset

func (m *ContainerLaunchContextProto) Reset()

func (*ContainerLaunchContextProto) String

func (m *ContainerLaunchContextProto) String() string

type ContainerManagementProtocolService

type ContainerManagementProtocolService interface {
	StartContainers(in *StartContainersRequestProto, out *StartContainersResponseProto) error
	StopContainers(in *StopContainersRequestProto, out *StopContainersResponseProto) error
	GetContainerStatuses(in *GetContainerStatusesRequestProto, out *GetContainerStatusesResponseProto) error
}

func DialContainerManagementProtocolService

func DialContainerManagementProtocolService(host string, port int) (ContainerManagementProtocolService, error)

DialContainerManagementProtocolService connects to an ContainerManagementProtocolService at the specified network address.

type ContainerManagementProtocolServiceClient

type ContainerManagementProtocolServiceClient struct {
	*hadoop_ipc_client.Client
}

func (*ContainerManagementProtocolServiceClient) GetContainerStatuses

func (*ContainerManagementProtocolServiceClient) StartContainers

func (*ContainerManagementProtocolServiceClient) StopContainers

type ContainerProto

type ContainerProto struct {
	Id               *ContainerIdProto         `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	NodeId           *NodeIdProto              `protobuf:"bytes,2,opt,name=nodeId" json:"nodeId,omitempty"`
	NodeHttpAddress  *string                   `protobuf:"bytes,3,opt,name=node_http_address" json:"node_http_address,omitempty"`
	Resource         *ResourceProto            `protobuf:"bytes,4,opt,name=resource" json:"resource,omitempty"`
	Priority         *PriorityProto            `protobuf:"bytes,5,opt,name=priority" json:"priority,omitempty"`
	ContainerToken   *hadoop_common.TokenProto `protobuf:"bytes,6,opt,name=container_token" json:"container_token,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ContainerProto) GetContainerToken

func (m *ContainerProto) GetContainerToken() *hadoop_common.TokenProto

func (*ContainerProto) GetId

func (m *ContainerProto) GetId() *ContainerIdProto

func (*ContainerProto) GetNodeHttpAddress

func (m *ContainerProto) GetNodeHttpAddress() string

func (*ContainerProto) GetNodeId

func (m *ContainerProto) GetNodeId() *NodeIdProto

func (*ContainerProto) GetPriority

func (m *ContainerProto) GetPriority() *PriorityProto

func (*ContainerProto) GetResource

func (m *ContainerProto) GetResource() *ResourceProto

func (*ContainerProto) ProtoMessage

func (*ContainerProto) ProtoMessage()

func (*ContainerProto) Reset

func (m *ContainerProto) Reset()

func (*ContainerProto) String

func (m *ContainerProto) String() string

type ContainerReportProto

type ContainerReportProto struct {
	ContainerId         *ContainerIdProto    `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	Resource            *ResourceProto       `protobuf:"bytes,2,opt,name=resource" json:"resource,omitempty"`
	NodeId              *NodeIdProto         `protobuf:"bytes,3,opt,name=node_id" json:"node_id,omitempty"`
	Priority            *PriorityProto       `protobuf:"bytes,4,opt,name=priority" json:"priority,omitempty"`
	CreationTime        *int64               `protobuf:"varint,5,opt,name=creation_time" json:"creation_time,omitempty"`
	FinishTime          *int64               `protobuf:"varint,6,opt,name=finish_time" json:"finish_time,omitempty"`
	DiagnosticsInfo     *string              `protobuf:"bytes,7,opt,name=diagnostics_info,def=N/A" json:"diagnostics_info,omitempty"`
	LogUrl              *string              `protobuf:"bytes,8,opt,name=log_url" json:"log_url,omitempty"`
	ContainerExitStatus *int32               `protobuf:"varint,9,opt,name=container_exit_status" json:"container_exit_status,omitempty"`
	ContainerState      *ContainerStateProto `protobuf:"varint,10,opt,name=container_state,enum=hadoop.yarn.ContainerStateProto" json:"container_state,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*ContainerReportProto) GetContainerExitStatus

func (m *ContainerReportProto) GetContainerExitStatus() int32

func (*ContainerReportProto) GetContainerId

func (m *ContainerReportProto) GetContainerId() *ContainerIdProto

func (*ContainerReportProto) GetContainerState

func (m *ContainerReportProto) GetContainerState() ContainerStateProto

func (*ContainerReportProto) GetCreationTime

func (m *ContainerReportProto) GetCreationTime() int64

func (*ContainerReportProto) GetDiagnosticsInfo

func (m *ContainerReportProto) GetDiagnosticsInfo() string

func (*ContainerReportProto) GetFinishTime

func (m *ContainerReportProto) GetFinishTime() int64

func (*ContainerReportProto) GetLogUrl

func (m *ContainerReportProto) GetLogUrl() string

func (*ContainerReportProto) GetNodeId

func (m *ContainerReportProto) GetNodeId() *NodeIdProto

func (*ContainerReportProto) GetPriority

func (m *ContainerReportProto) GetPriority() *PriorityProto

func (*ContainerReportProto) GetResource

func (m *ContainerReportProto) GetResource() *ResourceProto

func (*ContainerReportProto) ProtoMessage

func (*ContainerReportProto) ProtoMessage()

func (*ContainerReportProto) Reset

func (m *ContainerReportProto) Reset()

func (*ContainerReportProto) String

func (m *ContainerReportProto) String() string

type ContainerResourceDecreaseProto

type ContainerResourceDecreaseProto struct {
	ContainerId      *ContainerIdProto `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	Capability       *ResourceProto    `protobuf:"bytes,2,opt,name=capability" json:"capability,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*ContainerResourceDecreaseProto) GetCapability

func (m *ContainerResourceDecreaseProto) GetCapability() *ResourceProto

func (*ContainerResourceDecreaseProto) GetContainerId

func (m *ContainerResourceDecreaseProto) GetContainerId() *ContainerIdProto

func (*ContainerResourceDecreaseProto) ProtoMessage

func (*ContainerResourceDecreaseProto) ProtoMessage()

func (*ContainerResourceDecreaseProto) Reset

func (m *ContainerResourceDecreaseProto) Reset()

func (*ContainerResourceDecreaseProto) String

type ContainerResourceIncreaseProto

type ContainerResourceIncreaseProto struct {
	ContainerId      *ContainerIdProto         `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	Capability       *ResourceProto            `protobuf:"bytes,2,opt,name=capability" json:"capability,omitempty"`
	ContainerToken   *hadoop_common.TokenProto `protobuf:"bytes,3,opt,name=container_token" json:"container_token,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ContainerResourceIncreaseProto) GetCapability

func (m *ContainerResourceIncreaseProto) GetCapability() *ResourceProto

func (*ContainerResourceIncreaseProto) GetContainerId

func (m *ContainerResourceIncreaseProto) GetContainerId() *ContainerIdProto

func (*ContainerResourceIncreaseProto) GetContainerToken

func (*ContainerResourceIncreaseProto) ProtoMessage

func (*ContainerResourceIncreaseProto) ProtoMessage()

func (*ContainerResourceIncreaseProto) Reset

func (m *ContainerResourceIncreaseProto) Reset()

func (*ContainerResourceIncreaseProto) String

type ContainerResourceIncreaseRequestProto

type ContainerResourceIncreaseRequestProto struct {
	ContainerId      *ContainerIdProto `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	Capability       *ResourceProto    `protobuf:"bytes,2,opt,name=capability" json:"capability,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*ContainerResourceIncreaseRequestProto) GetCapability

func (*ContainerResourceIncreaseRequestProto) GetContainerId

func (*ContainerResourceIncreaseRequestProto) ProtoMessage

func (*ContainerResourceIncreaseRequestProto) ProtoMessage()

func (*ContainerResourceIncreaseRequestProto) Reset

func (*ContainerResourceIncreaseRequestProto) String

type ContainerStateProto

type ContainerStateProto int32
const (
	ContainerStateProto_C_NEW      ContainerStateProto = 1
	ContainerStateProto_C_RUNNING  ContainerStateProto = 2
	ContainerStateProto_C_COMPLETE ContainerStateProto = 3
)

func (ContainerStateProto) Enum

func (ContainerStateProto) MarshalJSON

func (x ContainerStateProto) MarshalJSON() ([]byte, error)

func (ContainerStateProto) String

func (x ContainerStateProto) String() string

func (*ContainerStateProto) UnmarshalJSON

func (x *ContainerStateProto) UnmarshalJSON(data []byte) error

type ContainerStatusProto

type ContainerStatusProto struct {
	ContainerId      *ContainerIdProto    `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	State            *ContainerStateProto `protobuf:"varint,2,opt,name=state,enum=hadoop.yarn.ContainerStateProto" json:"state,omitempty"`
	Diagnostics      *string              `protobuf:"bytes,3,opt,name=diagnostics,def=N/A" json:"diagnostics,omitempty"`
	ExitStatus       *int32               `protobuf:"varint,4,opt,name=exit_status,def=-1000" json:"exit_status,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*ContainerStatusProto) GetContainerId

func (m *ContainerStatusProto) GetContainerId() *ContainerIdProto

func (*ContainerStatusProto) GetDiagnostics

func (m *ContainerStatusProto) GetDiagnostics() string

func (*ContainerStatusProto) GetExitStatus

func (m *ContainerStatusProto) GetExitStatus() int32

func (*ContainerStatusProto) GetState

func (*ContainerStatusProto) ProtoMessage

func (*ContainerStatusProto) ProtoMessage()

func (*ContainerStatusProto) Reset

func (m *ContainerStatusProto) Reset()

func (*ContainerStatusProto) String

func (m *ContainerStatusProto) String() string

type FinalApplicationStatusProto

type FinalApplicationStatusProto int32
const (
	FinalApplicationStatusProto_APP_UNDEFINED FinalApplicationStatusProto = 0
	FinalApplicationStatusProto_APP_SUCCEEDED FinalApplicationStatusProto = 1
	FinalApplicationStatusProto_APP_FAILED    FinalApplicationStatusProto = 2
	FinalApplicationStatusProto_APP_KILLED    FinalApplicationStatusProto = 3
)

func (FinalApplicationStatusProto) Enum

func (FinalApplicationStatusProto) MarshalJSON

func (x FinalApplicationStatusProto) MarshalJSON() ([]byte, error)

func (FinalApplicationStatusProto) String

func (*FinalApplicationStatusProto) UnmarshalJSON

func (x *FinalApplicationStatusProto) UnmarshalJSON(data []byte) error

type FinishApplicationMasterRequestProto

type FinishApplicationMasterRequestProto struct {
	Diagnostics            *string                      `protobuf:"bytes,1,opt,name=diagnostics" json:"diagnostics,omitempty"`
	TrackingUrl            *string                      `protobuf:"bytes,2,opt,name=tracking_url" json:"tracking_url,omitempty"`
	FinalApplicationStatus *FinalApplicationStatusProto `` /* 140-byte string literal not displayed */
	XXX_unrecognized       []byte                       `json:"-"`
}

func (*FinishApplicationMasterRequestProto) GetDiagnostics

func (m *FinishApplicationMasterRequestProto) GetDiagnostics() string

func (*FinishApplicationMasterRequestProto) GetFinalApplicationStatus

func (*FinishApplicationMasterRequestProto) GetTrackingUrl

func (m *FinishApplicationMasterRequestProto) GetTrackingUrl() string

func (*FinishApplicationMasterRequestProto) ProtoMessage

func (*FinishApplicationMasterRequestProto) ProtoMessage()

func (*FinishApplicationMasterRequestProto) Reset

func (*FinishApplicationMasterRequestProto) String

type FinishApplicationMasterResponseProto

type FinishApplicationMasterResponseProto struct {
	IsUnregistered   *bool  `protobuf:"varint,1,opt,name=isUnregistered,def=0" json:"isUnregistered,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*FinishApplicationMasterResponseProto) GetIsUnregistered

func (m *FinishApplicationMasterResponseProto) GetIsUnregistered() bool

func (*FinishApplicationMasterResponseProto) ProtoMessage

func (*FinishApplicationMasterResponseProto) ProtoMessage()

func (*FinishApplicationMasterResponseProto) Reset

func (*FinishApplicationMasterResponseProto) String

type GetApplicationAttemptReportRequestProto

type GetApplicationAttemptReportRequestProto struct {
	ApplicationAttemptId *ApplicationAttemptIdProto `protobuf:"bytes,1,opt,name=application_attempt_id" json:"application_attempt_id,omitempty"`
	XXX_unrecognized     []byte                     `json:"-"`
}

func (*GetApplicationAttemptReportRequestProto) GetApplicationAttemptId

func (*GetApplicationAttemptReportRequestProto) ProtoMessage

func (*GetApplicationAttemptReportRequestProto) Reset

func (*GetApplicationAttemptReportRequestProto) String

type GetApplicationAttemptReportResponseProto

type GetApplicationAttemptReportResponseProto struct {
	ApplicationAttemptReport *ApplicationAttemptReportProto `protobuf:"bytes,1,opt,name=application_attempt_report" json:"application_attempt_report,omitempty"`
	XXX_unrecognized         []byte                         `json:"-"`
}

func (*GetApplicationAttemptReportResponseProto) GetApplicationAttemptReport

func (*GetApplicationAttemptReportResponseProto) ProtoMessage

func (*GetApplicationAttemptReportResponseProto) Reset

func (*GetApplicationAttemptReportResponseProto) String

type GetApplicationAttemptsRequestProto

type GetApplicationAttemptsRequestProto struct {
	ApplicationId    *ApplicationIdProto `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GetApplicationAttemptsRequestProto) GetApplicationId

func (*GetApplicationAttemptsRequestProto) ProtoMessage

func (*GetApplicationAttemptsRequestProto) ProtoMessage()

func (*GetApplicationAttemptsRequestProto) Reset

func (*GetApplicationAttemptsRequestProto) String

type GetApplicationAttemptsResponseProto

type GetApplicationAttemptsResponseProto struct {
	ApplicationAttempts []*ApplicationAttemptReportProto `protobuf:"bytes,1,rep,name=application_attempts" json:"application_attempts,omitempty"`
	XXX_unrecognized    []byte                           `json:"-"`
}

func (*GetApplicationAttemptsResponseProto) GetApplicationAttempts

func (*GetApplicationAttemptsResponseProto) ProtoMessage

func (*GetApplicationAttemptsResponseProto) ProtoMessage()

func (*GetApplicationAttemptsResponseProto) Reset

func (*GetApplicationAttemptsResponseProto) String

type GetApplicationReportRequestProto

type GetApplicationReportRequestProto struct {
	ApplicationId    *ApplicationIdProto `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GetApplicationReportRequestProto) GetApplicationId

func (*GetApplicationReportRequestProto) ProtoMessage

func (*GetApplicationReportRequestProto) ProtoMessage()

func (*GetApplicationReportRequestProto) Reset

func (*GetApplicationReportRequestProto) String

type GetApplicationReportResponseProto

type GetApplicationReportResponseProto struct {
	ApplicationReport *ApplicationReportProto `protobuf:"bytes,1,opt,name=application_report" json:"application_report,omitempty"`
	XXX_unrecognized  []byte                  `json:"-"`
}

func (*GetApplicationReportResponseProto) GetApplicationReport

func (m *GetApplicationReportResponseProto) GetApplicationReport() *ApplicationReportProto

func (*GetApplicationReportResponseProto) ProtoMessage

func (*GetApplicationReportResponseProto) ProtoMessage()

func (*GetApplicationReportResponseProto) Reset

func (*GetApplicationReportResponseProto) String

type GetApplicationsRequestProto

type GetApplicationsRequestProto struct {
	ApplicationTypes  []string                       `protobuf:"bytes,1,rep,name=application_types" json:"application_types,omitempty"`
	ApplicationStates []YarnApplicationStateProto    `` /* 126-byte string literal not displayed */
	Users             []string                       `protobuf:"bytes,3,rep,name=users" json:"users,omitempty"`
	Queues            []string                       `protobuf:"bytes,4,rep,name=queues" json:"queues,omitempty"`
	Limit             *int64                         `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
	StartBegin        *int64                         `protobuf:"varint,6,opt,name=start_begin" json:"start_begin,omitempty"`
	StartEnd          *int64                         `protobuf:"varint,7,opt,name=start_end" json:"start_end,omitempty"`
	FinishBegin       *int64                         `protobuf:"varint,8,opt,name=finish_begin" json:"finish_begin,omitempty"`
	FinishEnd         *int64                         `protobuf:"varint,9,opt,name=finish_end" json:"finish_end,omitempty"`
	ApplicationTags   []string                       `protobuf:"bytes,10,rep,name=applicationTags" json:"applicationTags,omitempty"`
	Scope             *ApplicationsRequestScopeProto `protobuf:"varint,11,opt,name=scope,enum=hadoop.yarn.ApplicationsRequestScopeProto,def=0" json:"scope,omitempty"`
	XXX_unrecognized  []byte                         `json:"-"`
}

func (*GetApplicationsRequestProto) GetApplicationStates

func (m *GetApplicationsRequestProto) GetApplicationStates() []YarnApplicationStateProto

func (*GetApplicationsRequestProto) GetApplicationTags

func (m *GetApplicationsRequestProto) GetApplicationTags() []string

func (*GetApplicationsRequestProto) GetApplicationTypes

func (m *GetApplicationsRequestProto) GetApplicationTypes() []string

func (*GetApplicationsRequestProto) GetFinishBegin

func (m *GetApplicationsRequestProto) GetFinishBegin() int64

func (*GetApplicationsRequestProto) GetFinishEnd

func (m *GetApplicationsRequestProto) GetFinishEnd() int64

func (*GetApplicationsRequestProto) GetLimit

func (m *GetApplicationsRequestProto) GetLimit() int64

func (*GetApplicationsRequestProto) GetQueues

func (m *GetApplicationsRequestProto) GetQueues() []string

func (*GetApplicationsRequestProto) GetScope

func (*GetApplicationsRequestProto) GetStartBegin

func (m *GetApplicationsRequestProto) GetStartBegin() int64

func (*GetApplicationsRequestProto) GetStartEnd

func (m *GetApplicationsRequestProto) GetStartEnd() int64

func (*GetApplicationsRequestProto) GetUsers

func (m *GetApplicationsRequestProto) GetUsers() []string

func (*GetApplicationsRequestProto) ProtoMessage

func (*GetApplicationsRequestProto) ProtoMessage()

func (*GetApplicationsRequestProto) Reset

func (m *GetApplicationsRequestProto) Reset()

func (*GetApplicationsRequestProto) String

func (m *GetApplicationsRequestProto) String() string

type GetApplicationsResponseProto

type GetApplicationsResponseProto struct {
	Applications     []*ApplicationReportProto `protobuf:"bytes,1,rep,name=applications" json:"applications,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*GetApplicationsResponseProto) GetApplications

func (m *GetApplicationsResponseProto) GetApplications() []*ApplicationReportProto

func (*GetApplicationsResponseProto) ProtoMessage

func (*GetApplicationsResponseProto) ProtoMessage()

func (*GetApplicationsResponseProto) Reset

func (m *GetApplicationsResponseProto) Reset()

func (*GetApplicationsResponseProto) String

type GetClusterMetricsRequestProto

type GetClusterMetricsRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetClusterMetricsRequestProto) ProtoMessage

func (*GetClusterMetricsRequestProto) ProtoMessage()

func (*GetClusterMetricsRequestProto) Reset

func (m *GetClusterMetricsRequestProto) Reset()

func (*GetClusterMetricsRequestProto) String

type GetClusterMetricsResponseProto

type GetClusterMetricsResponseProto struct {
	ClusterMetrics   *YarnClusterMetricsProto `protobuf:"bytes,1,opt,name=cluster_metrics" json:"cluster_metrics,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*GetClusterMetricsResponseProto) GetClusterMetrics

func (*GetClusterMetricsResponseProto) ProtoMessage

func (*GetClusterMetricsResponseProto) ProtoMessage()

func (*GetClusterMetricsResponseProto) Reset

func (m *GetClusterMetricsResponseProto) Reset()

func (*GetClusterMetricsResponseProto) String

type GetClusterNodesRequestProto

type GetClusterNodesRequestProto struct {
	NodeStates       []NodeStateProto `protobuf:"varint,1,rep,name=nodeStates,enum=hadoop.yarn.NodeStateProto" json:"nodeStates,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetClusterNodesRequestProto) GetNodeStates

func (m *GetClusterNodesRequestProto) GetNodeStates() []NodeStateProto

func (*GetClusterNodesRequestProto) ProtoMessage

func (*GetClusterNodesRequestProto) ProtoMessage()

func (*GetClusterNodesRequestProto) Reset

func (m *GetClusterNodesRequestProto) Reset()

func (*GetClusterNodesRequestProto) String

func (m *GetClusterNodesRequestProto) String() string

type GetClusterNodesResponseProto

type GetClusterNodesResponseProto struct {
	NodeReports      []*NodeReportProto `protobuf:"bytes,1,rep,name=nodeReports" json:"nodeReports,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*GetClusterNodesResponseProto) GetNodeReports

func (m *GetClusterNodesResponseProto) GetNodeReports() []*NodeReportProto

func (*GetClusterNodesResponseProto) ProtoMessage

func (*GetClusterNodesResponseProto) ProtoMessage()

func (*GetClusterNodesResponseProto) Reset

func (m *GetClusterNodesResponseProto) Reset()

func (*GetClusterNodesResponseProto) String

type GetContainerReportRequestProto

type GetContainerReportRequestProto struct {
	ContainerId      *ContainerIdProto `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*GetContainerReportRequestProto) GetContainerId

func (m *GetContainerReportRequestProto) GetContainerId() *ContainerIdProto

func (*GetContainerReportRequestProto) ProtoMessage

func (*GetContainerReportRequestProto) ProtoMessage()

func (*GetContainerReportRequestProto) Reset

func (m *GetContainerReportRequestProto) Reset()

func (*GetContainerReportRequestProto) String

type GetContainerReportResponseProto

type GetContainerReportResponseProto struct {
	ContainerReport  *ContainerReportProto `protobuf:"bytes,1,opt,name=container_report" json:"container_report,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*GetContainerReportResponseProto) GetContainerReport

func (m *GetContainerReportResponseProto) GetContainerReport() *ContainerReportProto

func (*GetContainerReportResponseProto) ProtoMessage

func (*GetContainerReportResponseProto) ProtoMessage()

func (*GetContainerReportResponseProto) Reset

func (*GetContainerReportResponseProto) String

type GetContainerStatusRequestProto

type GetContainerStatusRequestProto struct {
	ContainerId      *ContainerIdProto `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*GetContainerStatusRequestProto) GetContainerId

func (m *GetContainerStatusRequestProto) GetContainerId() *ContainerIdProto

func (*GetContainerStatusRequestProto) ProtoMessage

func (*GetContainerStatusRequestProto) ProtoMessage()

func (*GetContainerStatusRequestProto) Reset

func (m *GetContainerStatusRequestProto) Reset()

func (*GetContainerStatusRequestProto) String

type GetContainerStatusResponseProto

type GetContainerStatusResponseProto struct {
	Status           *ContainerStatusProto `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*GetContainerStatusResponseProto) GetStatus

func (*GetContainerStatusResponseProto) ProtoMessage

func (*GetContainerStatusResponseProto) ProtoMessage()

func (*GetContainerStatusResponseProto) Reset

func (*GetContainerStatusResponseProto) String

type GetContainerStatusesRequestProto

type GetContainerStatusesRequestProto struct {
	ContainerId      []*ContainerIdProto `protobuf:"bytes,1,rep,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GetContainerStatusesRequestProto) GetContainerId

func (m *GetContainerStatusesRequestProto) GetContainerId() []*ContainerIdProto

func (*GetContainerStatusesRequestProto) ProtoMessage

func (*GetContainerStatusesRequestProto) ProtoMessage()

func (*GetContainerStatusesRequestProto) Reset

func (*GetContainerStatusesRequestProto) String

type GetContainerStatusesResponseProto

type GetContainerStatusesResponseProto struct {
	Status           []*ContainerStatusProto       `protobuf:"bytes,1,rep,name=status" json:"status,omitempty"`
	FailedRequests   []*ContainerExceptionMapProto `protobuf:"bytes,2,rep,name=failed_requests" json:"failed_requests,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

func (*GetContainerStatusesResponseProto) GetFailedRequests

func (*GetContainerStatusesResponseProto) GetStatus

func (*GetContainerStatusesResponseProto) ProtoMessage

func (*GetContainerStatusesResponseProto) ProtoMessage()

func (*GetContainerStatusesResponseProto) Reset

func (*GetContainerStatusesResponseProto) String

type GetContainersRequestProto

type GetContainersRequestProto struct {
	ApplicationAttemptId *ApplicationAttemptIdProto `protobuf:"bytes,1,opt,name=application_attempt_id" json:"application_attempt_id,omitempty"`
	XXX_unrecognized     []byte                     `json:"-"`
}

func (*GetContainersRequestProto) GetApplicationAttemptId

func (m *GetContainersRequestProto) GetApplicationAttemptId() *ApplicationAttemptIdProto

func (*GetContainersRequestProto) ProtoMessage

func (*GetContainersRequestProto) ProtoMessage()

func (*GetContainersRequestProto) Reset

func (m *GetContainersRequestProto) Reset()

func (*GetContainersRequestProto) String

func (m *GetContainersRequestProto) String() string

type GetContainersResponseProto

type GetContainersResponseProto struct {
	Containers       []*ContainerReportProto `protobuf:"bytes,1,rep,name=containers" json:"containers,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*GetContainersResponseProto) GetContainers

func (m *GetContainersResponseProto) GetContainers() []*ContainerReportProto

func (*GetContainersResponseProto) ProtoMessage

func (*GetContainersResponseProto) ProtoMessage()

func (*GetContainersResponseProto) Reset

func (m *GetContainersResponseProto) Reset()

func (*GetContainersResponseProto) String

func (m *GetContainersResponseProto) String() string

type GetNewApplicationRequestProto

type GetNewApplicationRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetNewApplicationRequestProto) ProtoMessage

func (*GetNewApplicationRequestProto) ProtoMessage()

func (*GetNewApplicationRequestProto) Reset

func (m *GetNewApplicationRequestProto) Reset()

func (*GetNewApplicationRequestProto) String

type GetNewApplicationResponseProto

type GetNewApplicationResponseProto struct {
	ApplicationId     *ApplicationIdProto `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	MaximumCapability *ResourceProto      `protobuf:"bytes,2,opt,name=maximumCapability" json:"maximumCapability,omitempty"`
	XXX_unrecognized  []byte              `json:"-"`
}

func (*GetNewApplicationResponseProto) GetApplicationId

func (m *GetNewApplicationResponseProto) GetApplicationId() *ApplicationIdProto

func (*GetNewApplicationResponseProto) GetMaximumCapability

func (m *GetNewApplicationResponseProto) GetMaximumCapability() *ResourceProto

func (*GetNewApplicationResponseProto) ProtoMessage

func (*GetNewApplicationResponseProto) ProtoMessage()

func (*GetNewApplicationResponseProto) Reset

func (m *GetNewApplicationResponseProto) Reset()

func (*GetNewApplicationResponseProto) String

type GetQueueInfoRequestProto

type GetQueueInfoRequestProto struct {
	QueueName           *string `protobuf:"bytes,1,opt,name=queueName" json:"queueName,omitempty"`
	IncludeApplications *bool   `protobuf:"varint,2,opt,name=includeApplications" json:"includeApplications,omitempty"`
	IncludeChildQueues  *bool   `protobuf:"varint,3,opt,name=includeChildQueues" json:"includeChildQueues,omitempty"`
	Recursive           *bool   `protobuf:"varint,4,opt,name=recursive" json:"recursive,omitempty"`
	XXX_unrecognized    []byte  `json:"-"`
}

func (*GetQueueInfoRequestProto) GetIncludeApplications

func (m *GetQueueInfoRequestProto) GetIncludeApplications() bool

func (*GetQueueInfoRequestProto) GetIncludeChildQueues

func (m *GetQueueInfoRequestProto) GetIncludeChildQueues() bool

func (*GetQueueInfoRequestProto) GetQueueName

func (m *GetQueueInfoRequestProto) GetQueueName() string

func (*GetQueueInfoRequestProto) GetRecursive

func (m *GetQueueInfoRequestProto) GetRecursive() bool

func (*GetQueueInfoRequestProto) ProtoMessage

func (*GetQueueInfoRequestProto) ProtoMessage()

func (*GetQueueInfoRequestProto) Reset

func (m *GetQueueInfoRequestProto) Reset()

func (*GetQueueInfoRequestProto) String

func (m *GetQueueInfoRequestProto) String() string

type GetQueueInfoResponseProto

type GetQueueInfoResponseProto struct {
	QueueInfo        *QueueInfoProto `protobuf:"bytes,1,opt,name=queueInfo" json:"queueInfo,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GetQueueInfoResponseProto) GetQueueInfo

func (m *GetQueueInfoResponseProto) GetQueueInfo() *QueueInfoProto

func (*GetQueueInfoResponseProto) ProtoMessage

func (*GetQueueInfoResponseProto) ProtoMessage()

func (*GetQueueInfoResponseProto) Reset

func (m *GetQueueInfoResponseProto) Reset()

func (*GetQueueInfoResponseProto) String

func (m *GetQueueInfoResponseProto) String() string

type GetQueueUserAclsInfoRequestProto

type GetQueueUserAclsInfoRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetQueueUserAclsInfoRequestProto) ProtoMessage

func (*GetQueueUserAclsInfoRequestProto) ProtoMessage()

func (*GetQueueUserAclsInfoRequestProto) Reset

func (*GetQueueUserAclsInfoRequestProto) String

type GetQueueUserAclsInfoResponseProto

type GetQueueUserAclsInfoResponseProto struct {
	QueueUserAcls    []*QueueUserACLInfoProto `protobuf:"bytes,1,rep,name=queueUserAcls" json:"queueUserAcls,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*GetQueueUserAclsInfoResponseProto) GetQueueUserAcls

func (*GetQueueUserAclsInfoResponseProto) ProtoMessage

func (*GetQueueUserAclsInfoResponseProto) ProtoMessage()

func (*GetQueueUserAclsInfoResponseProto) Reset

func (*GetQueueUserAclsInfoResponseProto) String

type KillApplicationRequestProto

type KillApplicationRequestProto struct {
	ApplicationId    *ApplicationIdProto `protobuf:"bytes,1,opt,name=application_id" json:"application_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*KillApplicationRequestProto) GetApplicationId

func (m *KillApplicationRequestProto) GetApplicationId() *ApplicationIdProto

func (*KillApplicationRequestProto) ProtoMessage

func (*KillApplicationRequestProto) ProtoMessage()

func (*KillApplicationRequestProto) Reset

func (m *KillApplicationRequestProto) Reset()

func (*KillApplicationRequestProto) String

func (m *KillApplicationRequestProto) String() string

type KillApplicationResponseProto

type KillApplicationResponseProto struct {
	IsKillCompleted  *bool  `protobuf:"varint,1,opt,name=is_kill_completed,def=0" json:"is_kill_completed,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*KillApplicationResponseProto) GetIsKillCompleted

func (m *KillApplicationResponseProto) GetIsKillCompleted() bool

func (*KillApplicationResponseProto) ProtoMessage

func (*KillApplicationResponseProto) ProtoMessage()

func (*KillApplicationResponseProto) Reset

func (m *KillApplicationResponseProto) Reset()

func (*KillApplicationResponseProto) String

type LocalResourceProto

type LocalResourceProto struct {
	Resource         *URLProto                     `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	Size             *int64                        `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
	Timestamp        *int64                        `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	Type             *LocalResourceTypeProto       `protobuf:"varint,4,opt,name=type,enum=hadoop.yarn.LocalResourceTypeProto" json:"type,omitempty"`
	Visibility       *LocalResourceVisibilityProto `protobuf:"varint,5,opt,name=visibility,enum=hadoop.yarn.LocalResourceVisibilityProto" json:"visibility,omitempty"`
	Pattern          *string                       `protobuf:"bytes,6,opt,name=pattern" json:"pattern,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

func (*LocalResourceProto) GetPattern

func (m *LocalResourceProto) GetPattern() string

func (*LocalResourceProto) GetResource

func (m *LocalResourceProto) GetResource() *URLProto

func (*LocalResourceProto) GetSize

func (m *LocalResourceProto) GetSize() int64

func (*LocalResourceProto) GetTimestamp

func (m *LocalResourceProto) GetTimestamp() int64

func (*LocalResourceProto) GetType

func (*LocalResourceProto) GetVisibility

func (*LocalResourceProto) ProtoMessage

func (*LocalResourceProto) ProtoMessage()

func (*LocalResourceProto) Reset

func (m *LocalResourceProto) Reset()

func (*LocalResourceProto) String

func (m *LocalResourceProto) String() string

type LocalResourceTypeProto

type LocalResourceTypeProto int32
const (
	LocalResourceTypeProto_ARCHIVE LocalResourceTypeProto = 1
	LocalResourceTypeProto_FILE    LocalResourceTypeProto = 2
	LocalResourceTypeProto_PATTERN LocalResourceTypeProto = 3
)

func (LocalResourceTypeProto) Enum

func (LocalResourceTypeProto) MarshalJSON

func (x LocalResourceTypeProto) MarshalJSON() ([]byte, error)

func (LocalResourceTypeProto) String

func (x LocalResourceTypeProto) String() string

func (*LocalResourceTypeProto) UnmarshalJSON

func (x *LocalResourceTypeProto) UnmarshalJSON(data []byte) error

type LocalResourceVisibilityProto

type LocalResourceVisibilityProto int32
const (
	LocalResourceVisibilityProto_PUBLIC      LocalResourceVisibilityProto = 1
	LocalResourceVisibilityProto_PRIVATE     LocalResourceVisibilityProto = 2
	LocalResourceVisibilityProto_APPLICATION LocalResourceVisibilityProto = 3
)

func (LocalResourceVisibilityProto) Enum

func (LocalResourceVisibilityProto) MarshalJSON

func (x LocalResourceVisibilityProto) MarshalJSON() ([]byte, error)

func (LocalResourceVisibilityProto) String

func (*LocalResourceVisibilityProto) UnmarshalJSON

func (x *LocalResourceVisibilityProto) UnmarshalJSON(data []byte) error

type MoveApplicationAcrossQueuesRequestProto

type MoveApplicationAcrossQueuesRequestProto struct {
	ApplicationId    *ApplicationIdProto `protobuf:"bytes,1,req,name=application_id" json:"application_id,omitempty"`
	TargetQueue      *string             `protobuf:"bytes,2,req,name=target_queue" json:"target_queue,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*MoveApplicationAcrossQueuesRequestProto) GetApplicationId

func (*MoveApplicationAcrossQueuesRequestProto) GetTargetQueue

func (m *MoveApplicationAcrossQueuesRequestProto) GetTargetQueue() string

func (*MoveApplicationAcrossQueuesRequestProto) ProtoMessage

func (*MoveApplicationAcrossQueuesRequestProto) Reset

func (*MoveApplicationAcrossQueuesRequestProto) String

type MoveApplicationAcrossQueuesResponseProto

type MoveApplicationAcrossQueuesResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MoveApplicationAcrossQueuesResponseProto) ProtoMessage

func (*MoveApplicationAcrossQueuesResponseProto) Reset

func (*MoveApplicationAcrossQueuesResponseProto) String

type NMTokenProto

type NMTokenProto struct {
	NodeId           *NodeIdProto              `protobuf:"bytes,1,opt,name=nodeId" json:"nodeId,omitempty"`
	Token            *hadoop_common.TokenProto `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*NMTokenProto) GetNodeId

func (m *NMTokenProto) GetNodeId() *NodeIdProto

func (*NMTokenProto) GetToken

func (m *NMTokenProto) GetToken() *hadoop_common.TokenProto

func (*NMTokenProto) ProtoMessage

func (*NMTokenProto) ProtoMessage()

func (*NMTokenProto) Reset

func (m *NMTokenProto) Reset()

func (*NMTokenProto) String

func (m *NMTokenProto) String() string

type NodeIdProto

type NodeIdProto struct {
	Host             *string `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	Port             *int32  `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NodeIdProto) GetHost

func (m *NodeIdProto) GetHost() string

func (*NodeIdProto) GetPort

func (m *NodeIdProto) GetPort() int32

func (*NodeIdProto) ProtoMessage

func (*NodeIdProto) ProtoMessage()

func (*NodeIdProto) Reset

func (m *NodeIdProto) Reset()

func (*NodeIdProto) String

func (m *NodeIdProto) String() string

type NodeReportProto

type NodeReportProto struct {
	NodeId               *NodeIdProto    `protobuf:"bytes,1,opt,name=nodeId" json:"nodeId,omitempty"`
	HttpAddress          *string         `protobuf:"bytes,2,opt,name=httpAddress" json:"httpAddress,omitempty"`
	RackName             *string         `protobuf:"bytes,3,opt,name=rackName" json:"rackName,omitempty"`
	Used                 *ResourceProto  `protobuf:"bytes,4,opt,name=used" json:"used,omitempty"`
	Capability           *ResourceProto  `protobuf:"bytes,5,opt,name=capability" json:"capability,omitempty"`
	NumContainers        *int32          `protobuf:"varint,6,opt,name=numContainers" json:"numContainers,omitempty"`
	NodeState            *NodeStateProto `protobuf:"varint,7,opt,name=node_state,enum=hadoop.yarn.NodeStateProto" json:"node_state,omitempty"`
	HealthReport         *string         `protobuf:"bytes,8,opt,name=health_report" json:"health_report,omitempty"`
	LastHealthReportTime *int64          `protobuf:"varint,9,opt,name=last_health_report_time" json:"last_health_report_time,omitempty"`
	XXX_unrecognized     []byte          `json:"-"`
}

func (*NodeReportProto) GetCapability

func (m *NodeReportProto) GetCapability() *ResourceProto

func (*NodeReportProto) GetHealthReport

func (m *NodeReportProto) GetHealthReport() string

func (*NodeReportProto) GetHttpAddress

func (m *NodeReportProto) GetHttpAddress() string

func (*NodeReportProto) GetLastHealthReportTime

func (m *NodeReportProto) GetLastHealthReportTime() int64

func (*NodeReportProto) GetNodeId

func (m *NodeReportProto) GetNodeId() *NodeIdProto

func (*NodeReportProto) GetNodeState

func (m *NodeReportProto) GetNodeState() NodeStateProto

func (*NodeReportProto) GetNumContainers

func (m *NodeReportProto) GetNumContainers() int32

func (*NodeReportProto) GetRackName

func (m *NodeReportProto) GetRackName() string

func (*NodeReportProto) GetUsed

func (m *NodeReportProto) GetUsed() *ResourceProto

func (*NodeReportProto) ProtoMessage

func (*NodeReportProto) ProtoMessage()

func (*NodeReportProto) Reset

func (m *NodeReportProto) Reset()

func (*NodeReportProto) String

func (m *NodeReportProto) String() string

type NodeResourceMapProto

type NodeResourceMapProto struct {
	NodeId           *NodeIdProto         `protobuf:"bytes,1,opt,name=node_id" json:"node_id,omitempty"`
	ResourceOption   *ResourceOptionProto `protobuf:"bytes,2,opt,name=resource_option" json:"resource_option,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*NodeResourceMapProto) GetNodeId

func (m *NodeResourceMapProto) GetNodeId() *NodeIdProto

func (*NodeResourceMapProto) GetResourceOption

func (m *NodeResourceMapProto) GetResourceOption() *ResourceOptionProto

func (*NodeResourceMapProto) ProtoMessage

func (*NodeResourceMapProto) ProtoMessage()

func (*NodeResourceMapProto) Reset

func (m *NodeResourceMapProto) Reset()

func (*NodeResourceMapProto) String

func (m *NodeResourceMapProto) String() string

type NodeStateProto

type NodeStateProto int32
const (
	NodeStateProto_NS_NEW            NodeStateProto = 1
	NodeStateProto_NS_RUNNING        NodeStateProto = 2
	NodeStateProto_NS_UNHEALTHY      NodeStateProto = 3
	NodeStateProto_NS_DECOMMISSIONED NodeStateProto = 4
	NodeStateProto_NS_LOST           NodeStateProto = 5
	NodeStateProto_NS_REBOOTED       NodeStateProto = 6
)

func (NodeStateProto) Enum

func (x NodeStateProto) Enum() *NodeStateProto

func (NodeStateProto) MarshalJSON

func (x NodeStateProto) MarshalJSON() ([]byte, error)

func (NodeStateProto) String

func (x NodeStateProto) String() string

func (*NodeStateProto) UnmarshalJSON

func (x *NodeStateProto) UnmarshalJSON(data []byte) error

type PreemptionContainerProto

type PreemptionContainerProto struct {
	Id               *ContainerIdProto `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*PreemptionContainerProto) GetId

func (*PreemptionContainerProto) ProtoMessage

func (*PreemptionContainerProto) ProtoMessage()

func (*PreemptionContainerProto) Reset

func (m *PreemptionContainerProto) Reset()

func (*PreemptionContainerProto) String

func (m *PreemptionContainerProto) String() string

type PreemptionContractProto

type PreemptionContractProto struct {
	Resource         []*PreemptionResourceRequestProto `protobuf:"bytes,1,rep,name=resource" json:"resource,omitempty"`
	Container        []*PreemptionContainerProto       `protobuf:"bytes,2,rep,name=container" json:"container,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

func (*PreemptionContractProto) GetContainer

func (*PreemptionContractProto) GetResource

func (*PreemptionContractProto) ProtoMessage

func (*PreemptionContractProto) ProtoMessage()

func (*PreemptionContractProto) Reset

func (m *PreemptionContractProto) Reset()

func (*PreemptionContractProto) String

func (m *PreemptionContractProto) String() string

type PreemptionMessageProto

type PreemptionMessageProto struct {
	StrictContract   *StrictPreemptionContractProto `protobuf:"bytes,1,opt,name=strictContract" json:"strictContract,omitempty"`
	Contract         *PreemptionContractProto       `protobuf:"bytes,2,opt,name=contract" json:"contract,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func (*PreemptionMessageProto) GetContract

func (*PreemptionMessageProto) GetStrictContract

func (m *PreemptionMessageProto) GetStrictContract() *StrictPreemptionContractProto

func (*PreemptionMessageProto) ProtoMessage

func (*PreemptionMessageProto) ProtoMessage()

func (*PreemptionMessageProto) Reset

func (m *PreemptionMessageProto) Reset()

func (*PreemptionMessageProto) String

func (m *PreemptionMessageProto) String() string

type PreemptionResourceRequestProto

type PreemptionResourceRequestProto struct {
	Resource         *ResourceRequestProto `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*PreemptionResourceRequestProto) GetResource

func (*PreemptionResourceRequestProto) ProtoMessage

func (*PreemptionResourceRequestProto) ProtoMessage()

func (*PreemptionResourceRequestProto) Reset

func (m *PreemptionResourceRequestProto) Reset()

func (*PreemptionResourceRequestProto) String

type PriorityProto

type PriorityProto struct {
	Priority         *int32 `protobuf:"varint,1,opt,name=priority" json:"priority,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PriorityProto) GetPriority

func (m *PriorityProto) GetPriority() int32

func (*PriorityProto) ProtoMessage

func (*PriorityProto) ProtoMessage()

func (*PriorityProto) Reset

func (m *PriorityProto) Reset()

func (*PriorityProto) String

func (m *PriorityProto) String() string

type QueueACLProto

type QueueACLProto int32
const (
	QueueACLProto_QACL_SUBMIT_APPLICATIONS QueueACLProto = 1
	QueueACLProto_QACL_ADMINISTER_QUEUE    QueueACLProto = 2
)

func (QueueACLProto) Enum

func (x QueueACLProto) Enum() *QueueACLProto

func (QueueACLProto) MarshalJSON

func (x QueueACLProto) MarshalJSON() ([]byte, error)

func (QueueACLProto) String

func (x QueueACLProto) String() string

func (*QueueACLProto) UnmarshalJSON

func (x *QueueACLProto) UnmarshalJSON(data []byte) error

type QueueInfoProto

type QueueInfoProto struct {
	QueueName        *string                   `protobuf:"bytes,1,opt,name=queueName" json:"queueName,omitempty"`
	Capacity         *float32                  `protobuf:"fixed32,2,opt,name=capacity" json:"capacity,omitempty"`
	MaximumCapacity  *float32                  `protobuf:"fixed32,3,opt,name=maximumCapacity" json:"maximumCapacity,omitempty"`
	CurrentCapacity  *float32                  `protobuf:"fixed32,4,opt,name=currentCapacity" json:"currentCapacity,omitempty"`
	State            *QueueStateProto          `protobuf:"varint,5,opt,name=state,enum=hadoop.yarn.QueueStateProto" json:"state,omitempty"`
	ChildQueues      []*QueueInfoProto         `protobuf:"bytes,6,rep,name=childQueues" json:"childQueues,omitempty"`
	Applications     []*ApplicationReportProto `protobuf:"bytes,7,rep,name=applications" json:"applications,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*QueueInfoProto) GetApplications

func (m *QueueInfoProto) GetApplications() []*ApplicationReportProto

func (*QueueInfoProto) GetCapacity

func (m *QueueInfoProto) GetCapacity() float32

func (*QueueInfoProto) GetChildQueues

func (m *QueueInfoProto) GetChildQueues() []*QueueInfoProto

func (*QueueInfoProto) GetCurrentCapacity

func (m *QueueInfoProto) GetCurrentCapacity() float32

func (*QueueInfoProto) GetMaximumCapacity

func (m *QueueInfoProto) GetMaximumCapacity() float32

func (*QueueInfoProto) GetQueueName

func (m *QueueInfoProto) GetQueueName() string

func (*QueueInfoProto) GetState

func (m *QueueInfoProto) GetState() QueueStateProto

func (*QueueInfoProto) ProtoMessage

func (*QueueInfoProto) ProtoMessage()

func (*QueueInfoProto) Reset

func (m *QueueInfoProto) Reset()

func (*QueueInfoProto) String

func (m *QueueInfoProto) String() string

type QueueStateProto

type QueueStateProto int32
const (
	QueueStateProto_Q_STOPPED QueueStateProto = 1
	QueueStateProto_Q_RUNNING QueueStateProto = 2
)

func (QueueStateProto) Enum

func (x QueueStateProto) Enum() *QueueStateProto

func (QueueStateProto) MarshalJSON

func (x QueueStateProto) MarshalJSON() ([]byte, error)

func (QueueStateProto) String

func (x QueueStateProto) String() string

func (*QueueStateProto) UnmarshalJSON

func (x *QueueStateProto) UnmarshalJSON(data []byte) error

type QueueUserACLInfoProto

type QueueUserACLInfoProto struct {
	QueueName        *string         `protobuf:"bytes,1,opt,name=queueName" json:"queueName,omitempty"`
	UserAcls         []QueueACLProto `protobuf:"varint,2,rep,name=userAcls,enum=hadoop.yarn.QueueACLProto" json:"userAcls,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*QueueUserACLInfoProto) GetQueueName

func (m *QueueUserACLInfoProto) GetQueueName() string

func (*QueueUserACLInfoProto) GetUserAcls

func (m *QueueUserACLInfoProto) GetUserAcls() []QueueACLProto

func (*QueueUserACLInfoProto) ProtoMessage

func (*QueueUserACLInfoProto) ProtoMessage()

func (*QueueUserACLInfoProto) Reset

func (m *QueueUserACLInfoProto) Reset()

func (*QueueUserACLInfoProto) String

func (m *QueueUserACLInfoProto) String() string

type RegisterApplicationMasterRequestProto

type RegisterApplicationMasterRequestProto struct {
	Host             *string `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	RpcPort          *int32  `protobuf:"varint,2,opt,name=rpc_port" json:"rpc_port,omitempty"`
	TrackingUrl      *string `protobuf:"bytes,3,opt,name=tracking_url" json:"tracking_url,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

//////////////////////////////////////////////////// ///// AM_RM_Protocol /////////////////////////////// ////////////////////////////////////////////////////

func (*RegisterApplicationMasterRequestProto) GetHost

func (*RegisterApplicationMasterRequestProto) GetRpcPort

func (*RegisterApplicationMasterRequestProto) GetTrackingUrl

func (m *RegisterApplicationMasterRequestProto) GetTrackingUrl() string

func (*RegisterApplicationMasterRequestProto) ProtoMessage

func (*RegisterApplicationMasterRequestProto) ProtoMessage()

func (*RegisterApplicationMasterRequestProto) Reset

func (*RegisterApplicationMasterRequestProto) String

type RegisterApplicationMasterResponseProto

type RegisterApplicationMasterResponseProto struct {
	MaximumCapability              *ResourceProto            `protobuf:"bytes,1,opt,name=maximumCapability" json:"maximumCapability,omitempty"`
	ClientToAmTokenMasterKey       []byte                    `protobuf:"bytes,2,opt,name=client_to_am_token_master_key" json:"client_to_am_token_master_key,omitempty"`
	Application_ACLs               []*ApplicationACLMapProto `protobuf:"bytes,3,rep,name=application_ACLs" json:"application_ACLs,omitempty"`
	ContainersFromPreviousAttempts []*ContainerProto         `protobuf:"bytes,4,rep,name=containers_from_previous_attempts" json:"containers_from_previous_attempts,omitempty"`
	Queue                          *string                   `protobuf:"bytes,5,opt,name=queue" json:"queue,omitempty"`
	NmTokensFromPreviousAttempts   []*NMTokenProto           `protobuf:"bytes,6,rep,name=nm_tokens_from_previous_attempts" json:"nm_tokens_from_previous_attempts,omitempty"`
	XXX_unrecognized               []byte                    `json:"-"`
}

func (*RegisterApplicationMasterResponseProto) GetApplication_ACLs

func (*RegisterApplicationMasterResponseProto) GetClientToAmTokenMasterKey

func (m *RegisterApplicationMasterResponseProto) GetClientToAmTokenMasterKey() []byte

func (*RegisterApplicationMasterResponseProto) GetContainersFromPreviousAttempts

func (m *RegisterApplicationMasterResponseProto) GetContainersFromPreviousAttempts() []*ContainerProto

func (*RegisterApplicationMasterResponseProto) GetMaximumCapability

func (m *RegisterApplicationMasterResponseProto) GetMaximumCapability() *ResourceProto

func (*RegisterApplicationMasterResponseProto) GetNmTokensFromPreviousAttempts

func (m *RegisterApplicationMasterResponseProto) GetNmTokensFromPreviousAttempts() []*NMTokenProto

func (*RegisterApplicationMasterResponseProto) GetQueue

func (*RegisterApplicationMasterResponseProto) ProtoMessage

func (*RegisterApplicationMasterResponseProto) Reset

func (*RegisterApplicationMasterResponseProto) String

type ResourceBlacklistRequestProto

type ResourceBlacklistRequestProto struct {
	BlacklistAdditions []string `protobuf:"bytes,1,rep,name=blacklist_additions" json:"blacklist_additions,omitempty"`
	BlacklistRemovals  []string `protobuf:"bytes,2,rep,name=blacklist_removals" json:"blacklist_removals,omitempty"`
	XXX_unrecognized   []byte   `json:"-"`
}

func (*ResourceBlacklistRequestProto) GetBlacklistAdditions

func (m *ResourceBlacklistRequestProto) GetBlacklistAdditions() []string

func (*ResourceBlacklistRequestProto) GetBlacklistRemovals

func (m *ResourceBlacklistRequestProto) GetBlacklistRemovals() []string

func (*ResourceBlacklistRequestProto) ProtoMessage

func (*ResourceBlacklistRequestProto) ProtoMessage()

func (*ResourceBlacklistRequestProto) Reset

func (m *ResourceBlacklistRequestProto) Reset()

func (*ResourceBlacklistRequestProto) String

type ResourceOptionProto

type ResourceOptionProto struct {
	Resource          *ResourceProto `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	OverCommitTimeout *int32         `protobuf:"varint,2,opt,name=over_commit_timeout" json:"over_commit_timeout,omitempty"`
	XXX_unrecognized  []byte         `json:"-"`
}

func (*ResourceOptionProto) GetOverCommitTimeout

func (m *ResourceOptionProto) GetOverCommitTimeout() int32

func (*ResourceOptionProto) GetResource

func (m *ResourceOptionProto) GetResource() *ResourceProto

func (*ResourceOptionProto) ProtoMessage

func (*ResourceOptionProto) ProtoMessage()

func (*ResourceOptionProto) Reset

func (m *ResourceOptionProto) Reset()

func (*ResourceOptionProto) String

func (m *ResourceOptionProto) String() string

type ResourceProto

type ResourceProto struct {
	Memory           *int32 `protobuf:"varint,1,opt,name=memory" json:"memory,omitempty"`
	VirtualCores     *int32 `protobuf:"varint,2,opt,name=virtual_cores" json:"virtual_cores,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ResourceProto) GetMemory

func (m *ResourceProto) GetMemory() int32

func (*ResourceProto) GetVirtualCores

func (m *ResourceProto) GetVirtualCores() int32

func (*ResourceProto) ProtoMessage

func (*ResourceProto) ProtoMessage()

func (*ResourceProto) Reset

func (m *ResourceProto) Reset()

func (*ResourceProto) String

func (m *ResourceProto) String() string

type ResourceRequestProto

type ResourceRequestProto struct {
	Priority         *PriorityProto `protobuf:"bytes,1,opt,name=priority" json:"priority,omitempty"`
	ResourceName     *string        `protobuf:"bytes,2,opt,name=resource_name" json:"resource_name,omitempty"`
	Capability       *ResourceProto `protobuf:"bytes,3,opt,name=capability" json:"capability,omitempty"`
	NumContainers    *int32         `protobuf:"varint,4,opt,name=num_containers" json:"num_containers,omitempty"`
	RelaxLocality    *bool          `protobuf:"varint,5,opt,name=relax_locality,def=1" json:"relax_locality,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

////////////////////////////////////////////////////////////////////// //// From AM_RM_Protocol ///////////////////////////////////////////// //////////////////////////////////////////////////////////////////////

func (*ResourceRequestProto) GetCapability

func (m *ResourceRequestProto) GetCapability() *ResourceProto

func (*ResourceRequestProto) GetNumContainers

func (m *ResourceRequestProto) GetNumContainers() int32

func (*ResourceRequestProto) GetPriority

func (m *ResourceRequestProto) GetPriority() *PriorityProto

func (*ResourceRequestProto) GetRelaxLocality

func (m *ResourceRequestProto) GetRelaxLocality() bool

func (*ResourceRequestProto) GetResourceName

func (m *ResourceRequestProto) GetResourceName() string

func (*ResourceRequestProto) ProtoMessage

func (*ResourceRequestProto) ProtoMessage()

func (*ResourceRequestProto) Reset

func (m *ResourceRequestProto) Reset()

func (*ResourceRequestProto) String

func (m *ResourceRequestProto) String() string

type SerializedExceptionProto

type SerializedExceptionProto struct {
	Message          *string                   `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Trace            *string                   `protobuf:"bytes,2,opt,name=trace" json:"trace,omitempty"`
	ClassName        *string                   `protobuf:"bytes,3,opt,name=class_name" json:"class_name,omitempty"`
	Cause            *SerializedExceptionProto `protobuf:"bytes,4,opt,name=cause" json:"cause,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*SerializedExceptionProto) GetCause

func (*SerializedExceptionProto) GetClassName

func (m *SerializedExceptionProto) GetClassName() string

func (*SerializedExceptionProto) GetMessage

func (m *SerializedExceptionProto) GetMessage() string

func (*SerializedExceptionProto) GetTrace

func (m *SerializedExceptionProto) GetTrace() string

func (*SerializedExceptionProto) ProtoMessage

func (*SerializedExceptionProto) ProtoMessage()

func (*SerializedExceptionProto) Reset

func (m *SerializedExceptionProto) Reset()

func (*SerializedExceptionProto) String

func (m *SerializedExceptionProto) String() string

type StartContainerRequestProto

type StartContainerRequestProto struct {
	ContainerLaunchContext *ContainerLaunchContextProto `protobuf:"bytes,1,opt,name=container_launch_context" json:"container_launch_context,omitempty"`
	ContainerToken         *hadoop_common.TokenProto    `protobuf:"bytes,2,opt,name=container_token" json:"container_token,omitempty"`
	Container              *ContainerProto              `protobuf:"bytes,3,opt,name=container" json:"container,omitempty"`
	XXX_unrecognized       []byte                       `json:"-"`
}

func (*StartContainerRequestProto) GetContainer

func (m *StartContainerRequestProto) GetContainer() *ContainerProto

func (*StartContainerRequestProto) GetContainerLaunchContext

func (m *StartContainerRequestProto) GetContainerLaunchContext() *ContainerLaunchContextProto

func (*StartContainerRequestProto) GetContainerToken

func (m *StartContainerRequestProto) GetContainerToken() *hadoop_common.TokenProto

func (*StartContainerRequestProto) ProtoMessage

func (*StartContainerRequestProto) ProtoMessage()

func (*StartContainerRequestProto) Reset

func (m *StartContainerRequestProto) Reset()

func (*StartContainerRequestProto) String

func (m *StartContainerRequestProto) String() string

type StartContainerResponseProto

type StartContainerResponseProto struct {
	ServicesMetaData []*StringBytesMapProto `protobuf:"bytes,1,rep,name=services_meta_data" json:"services_meta_data,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*StartContainerResponseProto) GetServicesMetaData

func (m *StartContainerResponseProto) GetServicesMetaData() []*StringBytesMapProto

func (*StartContainerResponseProto) ProtoMessage

func (*StartContainerResponseProto) ProtoMessage()

func (*StartContainerResponseProto) Reset

func (m *StartContainerResponseProto) Reset()

func (*StartContainerResponseProto) String

func (m *StartContainerResponseProto) String() string

type StartContainersRequestProto

type StartContainersRequestProto struct {
	StartContainerRequest []*StartContainerRequestProto `protobuf:"bytes,1,rep,name=start_container_request" json:"start_container_request,omitempty"`
	XXX_unrecognized      []byte                        `json:"-"`
}

// bulk API records

func (*StartContainersRequestProto) GetStartContainerRequest

func (m *StartContainersRequestProto) GetStartContainerRequest() []*StartContainerRequestProto

func (*StartContainersRequestProto) ProtoMessage

func (*StartContainersRequestProto) ProtoMessage()

func (*StartContainersRequestProto) Reset

func (m *StartContainersRequestProto) Reset()

func (*StartContainersRequestProto) String

func (m *StartContainersRequestProto) String() string

type StartContainersResponseProto

type StartContainersResponseProto struct {
	ServicesMetaData  []*StringBytesMapProto        `protobuf:"bytes,1,rep,name=services_meta_data" json:"services_meta_data,omitempty"`
	SucceededRequests []*ContainerIdProto           `protobuf:"bytes,2,rep,name=succeeded_requests" json:"succeeded_requests,omitempty"`
	FailedRequests    []*ContainerExceptionMapProto `protobuf:"bytes,3,rep,name=failed_requests" json:"failed_requests,omitempty"`
	XXX_unrecognized  []byte                        `json:"-"`
}

func (*StartContainersResponseProto) GetFailedRequests

func (m *StartContainersResponseProto) GetFailedRequests() []*ContainerExceptionMapProto

func (*StartContainersResponseProto) GetServicesMetaData

func (m *StartContainersResponseProto) GetServicesMetaData() []*StringBytesMapProto

func (*StartContainersResponseProto) GetSucceededRequests

func (m *StartContainersResponseProto) GetSucceededRequests() []*ContainerIdProto

func (*StartContainersResponseProto) ProtoMessage

func (*StartContainersResponseProto) ProtoMessage()

func (*StartContainersResponseProto) Reset

func (m *StartContainersResponseProto) Reset()

func (*StartContainersResponseProto) String

type StopContainerRequestProto

type StopContainerRequestProto struct {
	ContainerId      *ContainerIdProto `protobuf:"bytes,1,opt,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*StopContainerRequestProto) GetContainerId

func (m *StopContainerRequestProto) GetContainerId() *ContainerIdProto

func (*StopContainerRequestProto) ProtoMessage

func (*StopContainerRequestProto) ProtoMessage()

func (*StopContainerRequestProto) Reset

func (m *StopContainerRequestProto) Reset()

func (*StopContainerRequestProto) String

func (m *StopContainerRequestProto) String() string

type StopContainerResponseProto

type StopContainerResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StopContainerResponseProto) ProtoMessage

func (*StopContainerResponseProto) ProtoMessage()

func (*StopContainerResponseProto) Reset

func (m *StopContainerResponseProto) Reset()

func (*StopContainerResponseProto) String

func (m *StopContainerResponseProto) String() string

type StopContainersRequestProto

type StopContainersRequestProto struct {
	ContainerId      []*ContainerIdProto `protobuf:"bytes,1,rep,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*StopContainersRequestProto) GetContainerId

func (m *StopContainersRequestProto) GetContainerId() []*ContainerIdProto

func (*StopContainersRequestProto) ProtoMessage

func (*StopContainersRequestProto) ProtoMessage()

func (*StopContainersRequestProto) Reset

func (m *StopContainersRequestProto) Reset()

func (*StopContainersRequestProto) String

func (m *StopContainersRequestProto) String() string

type StopContainersResponseProto

type StopContainersResponseProto struct {
	SucceededRequests []*ContainerIdProto           `protobuf:"bytes,1,rep,name=succeeded_requests" json:"succeeded_requests,omitempty"`
	FailedRequests    []*ContainerExceptionMapProto `protobuf:"bytes,2,rep,name=failed_requests" json:"failed_requests,omitempty"`
	XXX_unrecognized  []byte                        `json:"-"`
}

func (*StopContainersResponseProto) GetFailedRequests

func (m *StopContainersResponseProto) GetFailedRequests() []*ContainerExceptionMapProto

func (*StopContainersResponseProto) GetSucceededRequests

func (m *StopContainersResponseProto) GetSucceededRequests() []*ContainerIdProto

func (*StopContainersResponseProto) ProtoMessage

func (*StopContainersResponseProto) ProtoMessage()

func (*StopContainersResponseProto) Reset

func (m *StopContainersResponseProto) Reset()

func (*StopContainersResponseProto) String

func (m *StopContainersResponseProto) String() string

type StrictPreemptionContractProto

type StrictPreemptionContractProto struct {
	Container        []*PreemptionContainerProto `protobuf:"bytes,1,rep,name=container" json:"container,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*StrictPreemptionContractProto) GetContainer

func (*StrictPreemptionContractProto) ProtoMessage

func (*StrictPreemptionContractProto) ProtoMessage()

func (*StrictPreemptionContractProto) Reset

func (m *StrictPreemptionContractProto) Reset()

func (*StrictPreemptionContractProto) String

type StringBytesMapProto

type StringBytesMapProto struct {
	Key              *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value            []byte  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StringBytesMapProto) GetKey

func (m *StringBytesMapProto) GetKey() string

func (*StringBytesMapProto) GetValue

func (m *StringBytesMapProto) GetValue() []byte

func (*StringBytesMapProto) ProtoMessage

func (*StringBytesMapProto) ProtoMessage()

func (*StringBytesMapProto) Reset

func (m *StringBytesMapProto) Reset()

func (*StringBytesMapProto) String

func (m *StringBytesMapProto) String() string

type StringLocalResourceMapProto

type StringLocalResourceMapProto struct {
	Key              *string             `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value            *LocalResourceProto `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

////////////////////////////////////////////////////////////////////// //// From common////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////

func (*StringLocalResourceMapProto) GetKey

func (m *StringLocalResourceMapProto) GetKey() string

func (*StringLocalResourceMapProto) GetValue

func (*StringLocalResourceMapProto) ProtoMessage

func (*StringLocalResourceMapProto) ProtoMessage()

func (*StringLocalResourceMapProto) Reset

func (m *StringLocalResourceMapProto) Reset()

func (*StringLocalResourceMapProto) String

func (m *StringLocalResourceMapProto) String() string

type StringStringMapProto

type StringStringMapProto struct {
	Key              *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StringStringMapProto) GetKey

func (m *StringStringMapProto) GetKey() string

func (*StringStringMapProto) GetValue

func (m *StringStringMapProto) GetValue() string

func (*StringStringMapProto) ProtoMessage

func (*StringStringMapProto) ProtoMessage()

func (*StringStringMapProto) Reset

func (m *StringStringMapProto) Reset()

func (*StringStringMapProto) String

func (m *StringStringMapProto) String() string

type SubmitApplicationRequestProto

type SubmitApplicationRequestProto struct {
	ApplicationSubmissionContext *ApplicationSubmissionContextProto `protobuf:"bytes,1,opt,name=application_submission_context" json:"application_submission_context,omitempty"`
	XXX_unrecognized             []byte                             `json:"-"`
}

func (*SubmitApplicationRequestProto) GetApplicationSubmissionContext

func (m *SubmitApplicationRequestProto) GetApplicationSubmissionContext() *ApplicationSubmissionContextProto

func (*SubmitApplicationRequestProto) ProtoMessage

func (*SubmitApplicationRequestProto) ProtoMessage()

func (*SubmitApplicationRequestProto) Reset

func (m *SubmitApplicationRequestProto) Reset()

func (*SubmitApplicationRequestProto) String

type SubmitApplicationResponseProto

type SubmitApplicationResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SubmitApplicationResponseProto) ProtoMessage

func (*SubmitApplicationResponseProto) ProtoMessage()

func (*SubmitApplicationResponseProto) Reset

func (m *SubmitApplicationResponseProto) Reset()

func (*SubmitApplicationResponseProto) String

type URLProto

type URLProto struct {
	Scheme           *string `protobuf:"bytes,1,opt,name=scheme" json:"scheme,omitempty"`
	Host             *string `protobuf:"bytes,2,opt,name=host" json:"host,omitempty"`
	Port             *int32  `protobuf:"varint,3,opt,name=port" json:"port,omitempty"`
	File             *string `protobuf:"bytes,4,opt,name=file" json:"file,omitempty"`
	UserInfo         *string `protobuf:"bytes,5,opt,name=userInfo" json:"userInfo,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*URLProto) GetFile

func (m *URLProto) GetFile() string

func (*URLProto) GetHost

func (m *URLProto) GetHost() string

func (*URLProto) GetPort

func (m *URLProto) GetPort() int32

func (*URLProto) GetScheme

func (m *URLProto) GetScheme() string

func (*URLProto) GetUserInfo

func (m *URLProto) GetUserInfo() string

func (*URLProto) ProtoMessage

func (*URLProto) ProtoMessage()

func (*URLProto) Reset

func (m *URLProto) Reset()

func (*URLProto) String

func (m *URLProto) String() string

type YarnApplicationAttemptStateProto

type YarnApplicationAttemptStateProto int32
const (
	YarnApplicationAttemptStateProto_APP_ATTEMPT_NEW              YarnApplicationAttemptStateProto = 1
	YarnApplicationAttemptStateProto_APP_ATTEMPT_SUBMITTED        YarnApplicationAttemptStateProto = 2
	YarnApplicationAttemptStateProto_APP_ATTEMPT_SCHEDULED        YarnApplicationAttemptStateProto = 3
	YarnApplicationAttemptStateProto_APP_ATTEMPT_ALLOCATED_SAVING YarnApplicationAttemptStateProto = 4
	YarnApplicationAttemptStateProto_APP_ATTEMPT_ALLOCATED        YarnApplicationAttemptStateProto = 5
	YarnApplicationAttemptStateProto_APP_ATTEMPT_LAUNCHED         YarnApplicationAttemptStateProto = 6
	YarnApplicationAttemptStateProto_APP_ATTEMPT_FAILED           YarnApplicationAttemptStateProto = 7
	YarnApplicationAttemptStateProto_APP_ATTEMPT_RUNNING          YarnApplicationAttemptStateProto = 8
	YarnApplicationAttemptStateProto_APP_ATTEMPT_FINISHING        YarnApplicationAttemptStateProto = 9
	YarnApplicationAttemptStateProto_APP_ATTEMPT_FINISHED         YarnApplicationAttemptStateProto = 10
	YarnApplicationAttemptStateProto_APP_ATTEMPT_KILLED           YarnApplicationAttemptStateProto = 11
)

func (YarnApplicationAttemptStateProto) Enum

func (YarnApplicationAttemptStateProto) MarshalJSON

func (x YarnApplicationAttemptStateProto) MarshalJSON() ([]byte, error)

func (YarnApplicationAttemptStateProto) String

func (*YarnApplicationAttemptStateProto) UnmarshalJSON

func (x *YarnApplicationAttemptStateProto) UnmarshalJSON(data []byte) error

type YarnApplicationStateProto

type YarnApplicationStateProto int32
const (
	YarnApplicationStateProto_NEW        YarnApplicationStateProto = 1
	YarnApplicationStateProto_NEW_SAVING YarnApplicationStateProto = 2
	YarnApplicationStateProto_SUBMITTED  YarnApplicationStateProto = 3
	YarnApplicationStateProto_ACCEPTED   YarnApplicationStateProto = 4
	YarnApplicationStateProto_RUNNING    YarnApplicationStateProto = 5
	YarnApplicationStateProto_FINISHED   YarnApplicationStateProto = 6
	YarnApplicationStateProto_FAILED     YarnApplicationStateProto = 7
	YarnApplicationStateProto_KILLED     YarnApplicationStateProto = 8
)

func (YarnApplicationStateProto) Enum

func (YarnApplicationStateProto) MarshalJSON

func (x YarnApplicationStateProto) MarshalJSON() ([]byte, error)

func (YarnApplicationStateProto) String

func (x YarnApplicationStateProto) String() string

func (*YarnApplicationStateProto) UnmarshalJSON

func (x *YarnApplicationStateProto) UnmarshalJSON(data []byte) error

type YarnClusterMetricsProto

type YarnClusterMetricsProto struct {
	NumNodeManagers  *int32 `protobuf:"varint,1,opt,name=num_node_managers" json:"num_node_managers,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*YarnClusterMetricsProto) GetNumNodeManagers

func (m *YarnClusterMetricsProto) GetNumNodeManagers() int32

func (*YarnClusterMetricsProto) ProtoMessage

func (*YarnClusterMetricsProto) ProtoMessage()

func (*YarnClusterMetricsProto) Reset

func (m *YarnClusterMetricsProto) Reset()

func (*YarnClusterMetricsProto) String

func (m *YarnClusterMetricsProto) String() string

Directories

Path Synopsis
examples

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL