Versions in this module Expand all Collapse all v24 v24.1.0 Jan 15, 2019 v24.0.0 Dec 19, 2018 Changes in this version + func UserAgent() string + func Version() string + type AppState struct + State ApplicationState + type ApplicationState string + const ACCEPTED + const FAILED + const FINISHED + const FINISHING + const KILLED + const NEW + const NEWSAVING + const RUNNING + const SUBMITTED + func PossibleApplicationStateValues() []ApplicationState + type BaseClient struct + ClusterDNSName string + UserName string + func New(clusterDNSName string, userName string) BaseClient + func NewWithoutDefaults(clusterDNSName string, userName string) BaseClient + type JobClient struct + func NewJobClient(clusterDNSName string, userName string) JobClient + func (client JobClient) Get(ctx context.Context, jobID string) (result JobDetailRootJSONObject, err error) + func (client JobClient) GetAppState(ctx context.Context, appID string) (result AppState, err error) + func (client JobClient) GetAppStatePreparer(ctx context.Context, appID string) (*http.Request, error) + func (client JobClient) GetAppStateResponder(resp *http.Response) (result AppState, err error) + func (client JobClient) GetAppStateSender(req *http.Request) (*http.Response, error) + func (client JobClient) GetPreparer(ctx context.Context, jobID string) (*http.Request, error) + func (client JobClient) GetResponder(resp *http.Response) (result JobDetailRootJSONObject, err error) + func (client JobClient) GetSender(req *http.Request) (*http.Response, error) + func (client JobClient) Kill(ctx context.Context, jobID string) (result JobDetailRootJSONObject, err error) + func (client JobClient) KillPreparer(ctx context.Context, jobID string) (*http.Request, error) + func (client JobClient) KillResponder(resp *http.Response) (result JobDetailRootJSONObject, err error) + func (client JobClient) KillSender(req *http.Request) (*http.Response, error) + func (client JobClient) List(ctx context.Context) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobID(ctx context.Context, jobid string, numrecords *int32) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobIDPreparer(ctx context.Context, jobid string, numrecords *int32) (*http.Request, error) + func (client JobClient) ListAfterJobIDResponder(resp *http.Response) (result ListJobListJSONObject, err error) + func (client JobClient) ListAfterJobIDSender(req *http.Request) (*http.Response, error) + func (client JobClient) ListPreparer(ctx context.Context) (*http.Request, error) + func (client JobClient) ListResponder(resp *http.Response) (result ListJobListJSONObject, err error) + func (client JobClient) ListSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitHiveJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitHiveJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitHiveJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitHiveJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitMapReduceJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitMapReduceJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitMapReduceStreamingJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceStreamingJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitMapReduceStreamingJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitMapReduceStreamingJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitPigJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitPigJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitPigJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitPigJobSender(req *http.Request) (*http.Response, error) + func (client JobClient) SubmitSqoopJob(ctx context.Context, content io.ReadCloser) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitSqoopJobPreparer(ctx context.Context, content io.ReadCloser) (*http.Request, error) + func (client JobClient) SubmitSqoopJobResponder(resp *http.Response) (result JobSubmissionJSONResponse, err error) + func (client JobClient) SubmitSqoopJobSender(req *http.Request) (*http.Response, error) + type JobDetailRootJSONObject struct + Callback interface{} + Completed *string + ExitValue *int32 + ID *string + Msg interface{} + ParentID *string + PercentComplete *string + Profile *Profile + Status *Status + User *string + Userargs *Userargs + type JobID struct + ID *int64 + JtIdentifier *string + type JobListJSONObject struct + Detail *JobDetailRootJSONObject + ID *string + type JobOperationsErrorResponse struct + Error *string + type JobSubmissionJSONResponse struct + ID *string + type ListJobListJSONObject struct + Value *[]JobListJSONObject + type Profile struct + JobFile *string + JobID *string + JobName *string + QueueName *string + URL *string + User *string + type Status struct + CleanupProgress *float64 + FailureInfo *string + FinishTime *int64 + HistoryFile *string + JobACLs interface{} + JobComplete *bool + JobFile *string + JobID *string + JobName *string + JobPriority *string + MapProgress *float64 + NeededMem *int64 + NumReservedSlots *int32 + NumUsedSlots *int32 + Priority *string + Queue *string + ReduceProgress *float64 + ReservedMem *int64 + Retired *bool + RunState *int32 + SchedulingInfo *string + SetupProgress *float64 + StartTime *int64 + State *string + TrackingURL *string + Uber *bool + UsedMem *int64 + Username *string + type Userargs struct + Arg *[]string + Callback interface{} + Define *[]string + Enablelog *string + Execute *string + File interface{} + Files interface{} + Jar *string + Statusdir interface{} Other modules containing this package gopkg.in/Azure/azure-sdk-for-go.v23 gopkg.in/Azure/azure-sdk-for-go.v25 gopkg.in/Azure/azure-sdk-for-go.v26 gopkg.in/Azure/azure-sdk-for-go.v27 gopkg.in/Azure/azure-sdk-for-go.v28 gopkg.in/Azure/azure-sdk-for-go.v29 gopkg.in/Azure/azure-sdk-for-go.v30 gopkg.in/Azure/azure-sdk-for-go.v31 gopkg.in/Azure/azure-sdk-for-go.v32 gopkg.in/Azure/azure-sdk-for-go.v33 gopkg.in/Azure/azure-sdk-for-go.v34 gopkg.in/Azure/azure-sdk-for-go.v35 gopkg.in/Azure/azure-sdk-for-go.v36 gopkg.in/Azure/azure-sdk-for-go.v37 gopkg.in/Azure/azure-sdk-for-go.v38 gopkg.in/Azure/azure-sdk-for-go.v39 gopkg.in/Azure/azure-sdk-for-go.v40 gopkg.in/Azure/azure-sdk-for-go.v41 gopkg.in/Azure/azure-sdk-for-go.v42 gopkg.in/Azure/azure-sdk-for-go.v43 gopkg.in/Azure/azure-sdk-for-go.v44 gopkg.in/Azure/azure-sdk-for-go.v45 gopkg.in/Azure/azure-sdk-for-go.v46 gopkg.in/Azure/azure-sdk-for-go.v48
Go to main page