hadoop_yarn

package
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 (m *AllocateRequestProto) GetAsk() []*ResourceRequestProto

func (*AllocateRequestProto) GetBlacklistRequest 

func (m *AllocateRequestProto) GetBlacklistRequest() *ResourceBlacklistRequestProto

func (*AllocateRequestProto) GetIncreaseRequest 

func (m *AllocateRequestProto) GetIncreaseRequest() []*ContainerResourceIncreaseRequestProto

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 (m *AllocateResponseProto) GetPreempt() *PreemptionMessageProto

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 (m *ApplicationACLMapProto) GetAccessType() ApplicationAccessTypeProto

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 (x ApplicationAccessTypeProto) Enum() *ApplicationAccessTypeProto

func (ApplicationAccessTypeProto) MarshalJSON 

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

func (ApplicationAccessTypeProto) String 

func (x ApplicationAccessTypeProto) String() 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 (m *ApplicationAttemptReportProto) GetHost() string

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 

func (m *ApplicationAttemptReportProto) String() string

type ApplicationClientProtocolService 

type ApplicationClientProtocolService interface {
	GetNewApplication(in *GetNewApplicationRequestProto, out *GetNewApplicationResponseProto) error
	GetApplicationReport(in *GetApplicationReportRequestProto, out *GetApplicationReportResponseProto) error
	GetApplicationAttemptReport(in *GetApplicationAttemptReportRequestProto, out *GetApplicationAttemptReportResponseProto) error
	SubmitApplication(in *SubmitApplicationRequestProto, out *SubmitApplicationResponseProto) error
	ForceKillApplication(in *KillApplicationRequestProto, out *KillApplicationResponseProto) error
	GetClusterMetrics(in *GetClusterMetricsRequestProto, out *GetClusterMetricsResponseProto) error
	GetApplications(in *GetApplicationsRequestProto, out *GetApplicationsResponseProto) error
	GetClusterNodes(in *GetClusterNodesRequestProto, out *GetClusterNodesResponseProto) error
	GetQueueInfo(in *GetQueueInfoRequestProto, out *GetQueueInfoResponseProto) error
	GetQueueUserAcls(in *GetQueueUserAclsInfoRequestProto, out *GetQueueUserAclsInfoResponseProto) error
	GetDelegationToken(in *hadoop_common.GetDelegationTokenRequestProto, out *hadoop_common.GetDelegationTokenResponseProto) error
	RenewDelegationToken(in *hadoop_common.RenewDelegationTokenRequestProto, out *hadoop_common.RenewDelegationTokenResponseProto) error
	CancelDelegationToken(in *hadoop_common.CancelDelegationTokenRequestProto, out *hadoop_common.CancelDelegationTokenResponseProto) error
}

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) CancelDelegationToken 

func (c *ApplicationClientProtocolServiceClient) CancelDelegationToken(in *hadoop_common.CancelDelegationTokenRequestProto, out *hadoop_common.CancelDelegationTokenResponseProto) error

func (*ApplicationClientProtocolServiceClient) ForceKillApplication 

func (c *ApplicationClientProtocolServiceClient) ForceKillApplication(in *KillApplicationRequestProto, out *KillApplicationResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetApplicationAttemptReport 

func (c *ApplicationClientProtocolServiceClient) GetApplicationAttemptReport(in *GetApplicationAttemptReportRequestProto, out *GetApplicationAttemptReportResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetApplicationReport 

func (c *ApplicationClientProtocolServiceClient) GetApplicationReport(in *GetApplicationReportRequestProto, out *GetApplicationReportResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetApplications 

func (c *ApplicationClientProtocolServiceClient) GetApplications(in *GetApplicationsRequestProto, out *GetApplicationsResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetClusterMetrics 

func (c *ApplicationClientProtocolServiceClient) GetClusterMetrics(in *GetClusterMetricsRequestProto, out *GetClusterMetricsResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetClusterNodes 

func (c *ApplicationClientProtocolServiceClient) GetClusterNodes(in *GetClusterNodesRequestProto, out *GetClusterNodesResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetDelegationToken 

func (c *ApplicationClientProtocolServiceClient) GetDelegationToken(in *hadoop_common.GetDelegationTokenRequestProto, out *hadoop_common.GetDelegationTokenResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetNewApplication 

func (c *ApplicationClientProtocolServiceClient) GetNewApplication(in *GetNewApplicationRequestProto, out *GetNewApplicationResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetQueueInfo 

func (c *ApplicationClientProtocolServiceClient) GetQueueInfo(in *GetQueueInfoRequestProto, out *GetQueueInfoResponseProto) error

func (*ApplicationClientProtocolServiceClient) GetQueueUserAcls 

func (c *ApplicationClientProtocolServiceClient) GetQueueUserAcls(in *GetQueueUserAclsInfoRequestProto, out *GetQueueUserAclsInfoResponseProto) error

func (*ApplicationClientProtocolServiceClient) RenewDelegationToken 

func (c *ApplicationClientProtocolServiceClient) RenewDelegationToken(in *hadoop_common.RenewDelegationTokenRequestProto, out *hadoop_common.RenewDelegationTokenResponseProto) error

func (*ApplicationClientProtocolServiceClient) SubmitApplication 

func (c *ApplicationClientProtocolServiceClient) SubmitApplication(in *SubmitApplicationRequestProto, out *SubmitApplicationResponseProto) error

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 ApplicationMasterProtocolService 

type ApplicationMasterProtocolService interface {
	RegisterApplicationMaster(in *RegisterApplicationMasterRequestProto, out *RegisterApplicationMasterResponseProto) error
	FinishApplicationMaster(in *FinishApplicationMasterRequestProto, out *FinishApplicationMasterResponseProto) error
	Allocate(in *AllocateRequestProto, out *AllocateResponseProto) error
}

func DialApplicationMasterProtocolService 

func DialApplicationMasterProtocolService(conf yarn_conf.YarnConfiguration) (ApplicationMasterProtocolService, error)

type ApplicationMasterProtocolServiceClient 

type ApplicationMasterProtocolServiceClient struct {
	*hadoop_ipc_client.Client
}

func (*ApplicationMasterProtocolServiceClient) Allocate 

func (c *ApplicationMasterProtocolServiceClient) Allocate(in *AllocateRequestProto, out *AllocateResponseProto) error

func (*ApplicationMasterProtocolServiceClient) FinishApplicationMaster 

func (c *ApplicationMasterProtocolServiceClient) FinishApplicationMaster(in *FinishApplicationMasterRequestProto, out *FinishApplicationMasterResponseProto) error

func (*ApplicationMasterProtocolServiceClient) RegisterApplicationMaster 

func (c *ApplicationMasterProtocolServiceClient) RegisterApplicationMaster(in *RegisterApplicationMasterRequestProto, out *RegisterApplicationMasterResponseProto) error

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 (m *ApplicationReportProto) GetAppResource_Usage() *ApplicationResourceUsageReportProto

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 (m *ApplicationResourceUsageReportProto) Reset()

func (*ApplicationResourceUsageReportProto) String 

func (m *ApplicationResourceUsageReportProto) String() 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 (m *ApplicationSubmissionContextProto) GetAmContainerSpec() *ContainerLaunchContextProto

func (*ApplicationSubmissionContextProto) GetApplicationId 

func (m *ApplicationSubmissionContextProto) GetApplicationId() *ApplicationIdProto

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 (m *ApplicationSubmissionContextProto) GetPriority() *PriorityProto

func (*ApplicationSubmissionContextProto) GetQueue 

func (m *ApplicationSubmissionContextProto) GetQueue() string

func (*ApplicationSubmissionContextProto) GetResource 

func (m *ApplicationSubmissionContextProto) GetResource() *ResourceProto

func (*ApplicationSubmissionContextProto) GetUnmanagedAm 

func (m *ApplicationSubmissionContextProto) GetUnmanagedAm() bool

func (*ApplicationSubmissionContextProto) ProtoMessage 

func (*ApplicationSubmissionContextProto) ProtoMessage()

func (*ApplicationSubmissionContextProto) Reset 

func (m *ApplicationSubmissionContextProto) Reset()

func (*ApplicationSubmissionContextProto) String 

func (m *ApplicationSubmissionContextProto) String() 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 (x ApplicationsRequestScopeProto) Enum() *ApplicationsRequestScopeProto

func (ApplicationsRequestScopeProto) MarshalJSON 

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

func (ApplicationsRequestScopeProto) String 

func (x ApplicationsRequestScopeProto) String() 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 (m *ContainerExceptionMapProto) GetException() *SerializedExceptionProto

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 (x ContainerExitStatusProto) Enum() *ContainerExitStatusProto

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 (c *ContainerManagementProtocolServiceClient) GetContainerStatuses(in *GetContainerStatusesRequestProto, out *GetContainerStatusesResponseProto) error

func (*ContainerManagementProtocolServiceClient) StartContainers 

func (c *ContainerManagementProtocolServiceClient) StartContainers(in *StartContainersRequestProto, out *StartContainersResponseProto) error

func (*ContainerManagementProtocolServiceClient) StopContainers 

func (c *ContainerManagementProtocolServiceClient) StopContainers(in *StopContainersRequestProto, out *StopContainersResponseProto) error

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 

func (m *ContainerResourceDecreaseProto) String() 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 (m *ContainerResourceIncreaseProto) GetContainerToken() *hadoop_common.TokenProto

func (*ContainerResourceIncreaseProto) ProtoMessage 

func (*ContainerResourceIncreaseProto) ProtoMessage()

func (*ContainerResourceIncreaseProto) Reset 

func (m *ContainerResourceIncreaseProto) Reset()

func (*ContainerResourceIncreaseProto) String 

func (m *ContainerResourceIncreaseProto) String() 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 (m *ContainerResourceIncreaseRequestProto) GetCapability() *ResourceProto

func (*ContainerResourceIncreaseRequestProto) GetContainerId 

func (m *ContainerResourceIncreaseRequestProto) GetContainerId() *ContainerIdProto

func (*ContainerResourceIncreaseRequestProto) ProtoMessage 

func (*ContainerResourceIncreaseRequestProto) ProtoMessage()

func (*ContainerResourceIncreaseRequestProto) Reset 

func (m *ContainerResourceIncreaseRequestProto) Reset()

func (*ContainerResourceIncreaseRequestProto) String 

func (m *ContainerResourceIncreaseRequestProto) String() 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 (x ContainerStateProto) Enum() *ContainerStateProto

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 (m *ContainerStatusProto) GetState() ContainerStateProto

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 (x FinalApplicationStatusProto) Enum() *FinalApplicationStatusProto

func (FinalApplicationStatusProto) MarshalJSON 

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

func (FinalApplicationStatusProto) String 

func (x FinalApplicationStatusProto) String() 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 (m *FinishApplicationMasterRequestProto) GetFinalApplicationStatus() FinalApplicationStatusProto

func (*FinishApplicationMasterRequestProto) GetTrackingUrl 

func (m *FinishApplicationMasterRequestProto) GetTrackingUrl() string

func (*FinishApplicationMasterRequestProto) ProtoMessage 

func (*FinishApplicationMasterRequestProto) ProtoMessage()

func (*FinishApplicationMasterRequestProto) Reset 

func (m *FinishApplicationMasterRequestProto) Reset()

func (*FinishApplicationMasterRequestProto) String 

func (m *FinishApplicationMasterRequestProto) String() 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 (m *FinishApplicationMasterResponseProto) Reset()

func (*FinishApplicationMasterResponseProto) String 

func (m *FinishApplicationMasterResponseProto) String() 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 (m *GetApplicationAttemptReportRequestProto) GetApplicationAttemptId() *ApplicationAttemptIdProto

func (*GetApplicationAttemptReportRequestProto) ProtoMessage 

func (*GetApplicationAttemptReportRequestProto) ProtoMessage()

func (*GetApplicationAttemptReportRequestProto) Reset 

func (m *GetApplicationAttemptReportRequestProto) Reset()

func (*GetApplicationAttemptReportRequestProto) String 

func (m *GetApplicationAttemptReportRequestProto) String() 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 (m *GetApplicationAttemptReportResponseProto) GetApplicationAttemptReport() *ApplicationAttemptReportProto

func (*GetApplicationAttemptReportResponseProto) ProtoMessage 

func (*GetApplicationAttemptReportResponseProto) ProtoMessage()

func (*GetApplicationAttemptReportResponseProto) Reset 

func (m *GetApplicationAttemptReportResponseProto) Reset()

func (*GetApplicationAttemptReportResponseProto) String 

func (m *GetApplicationAttemptReportResponseProto) String() 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 (m *GetApplicationAttemptsRequestProto) GetApplicationId() *ApplicationIdProto

func (*GetApplicationAttemptsRequestProto) ProtoMessage 

func (*GetApplicationAttemptsRequestProto) ProtoMessage()

func (*GetApplicationAttemptsRequestProto) Reset 

func (m *GetApplicationAttemptsRequestProto) Reset()

func (*GetApplicationAttemptsRequestProto) String 

func (m *GetApplicationAttemptsRequestProto) String() 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 (m *GetApplicationAttemptsResponseProto) GetApplicationAttempts() []*ApplicationAttemptReportProto

func (*GetApplicationAttemptsResponseProto) ProtoMessage 

func (*GetApplicationAttemptsResponseProto) ProtoMessage()

func (*GetApplicationAttemptsResponseProto) Reset 

func (m *GetApplicationAttemptsResponseProto) Reset()

func (*GetApplicationAttemptsResponseProto) String 

func (m *GetApplicationAttemptsResponseProto) String() 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 (m *GetApplicationReportRequestProto) GetApplicationId() *ApplicationIdProto

func (*GetApplicationReportRequestProto) ProtoMessage 

func (*GetApplicationReportRequestProto) ProtoMessage()

func (*GetApplicationReportRequestProto) Reset 

func (m *GetApplicationReportRequestProto) Reset()

func (*GetApplicationReportRequestProto) String 

func (m *GetApplicationReportRequestProto) String() 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 (m *GetApplicationReportResponseProto) Reset()

func (*GetApplicationReportResponseProto) String 

func (m *GetApplicationReportResponseProto) String() 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 (m *GetApplicationsRequestProto) GetScope() ApplicationsRequestScopeProto

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 

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

func (m *GetClusterMetricsRequestProto) String() 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 (m *GetClusterMetricsResponseProto) GetClusterMetrics() *YarnClusterMetricsProto

func (*GetClusterMetricsResponseProto) ProtoMessage 

func (*GetClusterMetricsResponseProto) ProtoMessage()

func (*GetClusterMetricsResponseProto) Reset 

func (m *GetClusterMetricsResponseProto) Reset()

func (*GetClusterMetricsResponseProto) String 

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

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

func (m *GetContainerReportRequestProto) String() 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 (m *GetContainerReportResponseProto) Reset()

func (*GetContainerReportResponseProto) String 

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

func (m *GetContainerStatusRequestProto) String() 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 (m *GetContainerStatusResponseProto) GetStatus() *ContainerStatusProto

func (*GetContainerStatusResponseProto) ProtoMessage 

func (*GetContainerStatusResponseProto) ProtoMessage()

func (*GetContainerStatusResponseProto) Reset 

func (m *GetContainerStatusResponseProto) Reset()

func (*GetContainerStatusResponseProto) String 

func (m *GetContainerStatusResponseProto) String() 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 (m *GetContainerStatusesRequestProto) Reset()

func (*GetContainerStatusesRequestProto) String 

func (m *GetContainerStatusesRequestProto) String() 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 (m *GetContainerStatusesResponseProto) GetFailedRequests() []*ContainerExceptionMapProto

func (*GetContainerStatusesResponseProto) GetStatus 

func (m *GetContainerStatusesResponseProto) GetStatus() []*ContainerStatusProto

func (*GetContainerStatusesResponseProto) ProtoMessage 

func (*GetContainerStatusesResponseProto) ProtoMessage()

func (*GetContainerStatusesResponseProto) Reset 

func (m *GetContainerStatusesResponseProto) Reset()

func (*GetContainerStatusesResponseProto) String 

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

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

func (m *GetNewApplicationResponseProto) String() 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 (m *GetQueueUserAclsInfoRequestProto) Reset()

func (*GetQueueUserAclsInfoRequestProto) String 

func (m *GetQueueUserAclsInfoRequestProto) String() 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 (m *GetQueueUserAclsInfoResponseProto) GetQueueUserAcls() []*QueueUserACLInfoProto

func (*GetQueueUserAclsInfoResponseProto) ProtoMessage 

func (*GetQueueUserAclsInfoResponseProto) ProtoMessage()

func (*GetQueueUserAclsInfoResponseProto) Reset 

func (m *GetQueueUserAclsInfoResponseProto) Reset()

func (*GetQueueUserAclsInfoResponseProto) String 

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

func (m *KillApplicationResponseProto) String() 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 (m *LocalResourceProto) GetType() LocalResourceTypeProto

func (*LocalResourceProto) GetVisibility 

func (m *LocalResourceProto) GetVisibility() LocalResourceVisibilityProto

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 (x LocalResourceTypeProto) Enum() *LocalResourceTypeProto

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 (x LocalResourceVisibilityProto) Enum() *LocalResourceVisibilityProto

func (LocalResourceVisibilityProto) MarshalJSON 

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

func (LocalResourceVisibilityProto) String 

func (x LocalResourceVisibilityProto) String() 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 (m *MoveApplicationAcrossQueuesRequestProto) GetApplicationId() *ApplicationIdProto

func (*MoveApplicationAcrossQueuesRequestProto) GetTargetQueue 

func (m *MoveApplicationAcrossQueuesRequestProto) GetTargetQueue() string

func (*MoveApplicationAcrossQueuesRequestProto) ProtoMessage 

func (*MoveApplicationAcrossQueuesRequestProto) ProtoMessage()

func (*MoveApplicationAcrossQueuesRequestProto) Reset 

func (m *MoveApplicationAcrossQueuesRequestProto) Reset()

func (*MoveApplicationAcrossQueuesRequestProto) String 

func (m *MoveApplicationAcrossQueuesRequestProto) String() string

type MoveApplicationAcrossQueuesResponseProto 

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

func (*MoveApplicationAcrossQueuesResponseProto) ProtoMessage 

func (*MoveApplicationAcrossQueuesResponseProto) ProtoMessage()

func (*MoveApplicationAcrossQueuesResponseProto) Reset 

func (m *MoveApplicationAcrossQueuesResponseProto) Reset()

func (*MoveApplicationAcrossQueuesResponseProto) String 

func (m *MoveApplicationAcrossQueuesResponseProto) String() 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 (m *PreemptionContainerProto) GetId() *ContainerIdProto

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 (m *PreemptionContractProto) GetContainer() []*PreemptionContainerProto

func (*PreemptionContractProto) GetResource 

func (m *PreemptionContractProto) GetResource() []*PreemptionResourceRequestProto

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 (m *PreemptionMessageProto) GetContract() *PreemptionContractProto

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 (m *PreemptionResourceRequestProto) GetResource() *ResourceRequestProto

func (*PreemptionResourceRequestProto) ProtoMessage 

func (*PreemptionResourceRequestProto) ProtoMessage()

func (*PreemptionResourceRequestProto) Reset 

func (m *PreemptionResourceRequestProto) Reset()

func (*PreemptionResourceRequestProto) String 

func (m *PreemptionResourceRequestProto) String() 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 (m *RegisterApplicationMasterRequestProto) GetHost() string

func (*RegisterApplicationMasterRequestProto) GetRpcPort 

func (m *RegisterApplicationMasterRequestProto) GetRpcPort() int32

func (*RegisterApplicationMasterRequestProto) GetTrackingUrl 

func (m *RegisterApplicationMasterRequestProto) GetTrackingUrl() string

func (*RegisterApplicationMasterRequestProto) ProtoMessage 

func (*RegisterApplicationMasterRequestProto) ProtoMessage()

func (*RegisterApplicationMasterRequestProto) Reset 

func (m *RegisterApplicationMasterRequestProto) Reset()

func (*RegisterApplicationMasterRequestProto) String 

func (m *RegisterApplicationMasterRequestProto) String() 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 (m *RegisterApplicationMasterResponseProto) GetApplication_ACLs() []*ApplicationACLMapProto

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 (m *RegisterApplicationMasterResponseProto) GetQueue() string

func (*RegisterApplicationMasterResponseProto) ProtoMessage 

func (*RegisterApplicationMasterResponseProto) ProtoMessage()

func (*RegisterApplicationMasterResponseProto) Reset 

func (m *RegisterApplicationMasterResponseProto) Reset()

func (*RegisterApplicationMasterResponseProto) String 

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

func (m *ResourceBlacklistRequestProto) String() 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 (m *SerializedExceptionProto) GetCause() *SerializedExceptionProto

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 

func (m *StartContainersResponseProto) String() 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 (m *StrictPreemptionContractProto) GetContainer() []*PreemptionContainerProto

func (*StrictPreemptionContractProto) ProtoMessage 

func (*StrictPreemptionContractProto) ProtoMessage()

func (*StrictPreemptionContractProto) Reset 

func (m *StrictPreemptionContractProto) Reset()

func (*StrictPreemptionContractProto) String 

func (m *StrictPreemptionContractProto) String() 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 (m *StringLocalResourceMapProto) GetValue() *LocalResourceProto

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 

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

func (m *SubmitApplicationResponseProto) String() 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 (x YarnApplicationAttemptStateProto) Enum() *YarnApplicationAttemptStateProto

func (YarnApplicationAttemptStateProto) MarshalJSON 

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

func (YarnApplicationAttemptStateProto) String 

func (x YarnApplicationAttemptStateProto) String() 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 (x YarnApplicationStateProto) Enum() *YarnApplicationStateProto

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

Source Files

View all Source files

Directories

Path Synopsis
examples
dist_shell

Jump to

Keyboard shortcuts

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