1 package jobapi
2
3
4
5
6
7
8
9 import (
10 "context"
11 "github.com/Azure/azure-sdk-for-go/services/datalake/analytics/2016-11-01/job"
12 "github.com/Azure/go-autorest/autorest"
13 "github.com/Azure/go-autorest/autorest/date"
14 "github.com/gofrs/uuid"
15 )
16
17
18 type PipelineClientAPI interface {
19 Get(ctx context.Context, accountName string, pipelineIdentity uuid.UUID, startDateTime *date.Time, endDateTime *date.Time) (result job.PipelineInformation, err error)
20 List(ctx context.Context, accountName string, startDateTime *date.Time, endDateTime *date.Time) (result job.PipelineInformationListResultPage, err error)
21 ListComplete(ctx context.Context, accountName string, startDateTime *date.Time, endDateTime *date.Time) (result job.PipelineInformationListResultIterator, err error)
22 }
23
24 var _ PipelineClientAPI = (*job.PipelineClient)(nil)
25
26
27 type RecurrenceClientAPI interface {
28 Get(ctx context.Context, accountName string, recurrenceIdentity uuid.UUID, startDateTime *date.Time, endDateTime *date.Time) (result job.RecurrenceInformation, err error)
29 List(ctx context.Context, accountName string, startDateTime *date.Time, endDateTime *date.Time) (result job.RecurrenceInformationListResultPage, err error)
30 ListComplete(ctx context.Context, accountName string, startDateTime *date.Time, endDateTime *date.Time) (result job.RecurrenceInformationListResultIterator, err error)
31 }
32
33 var _ RecurrenceClientAPI = (*job.RecurrenceClient)(nil)
34
35
36 type ClientAPI interface {
37 Build(ctx context.Context, accountName string, parameters job.BuildJobParameters) (result job.Information, err error)
38 Cancel(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result autorest.Response, err error)
39 Create(ctx context.Context, accountName string, jobIdentity uuid.UUID, parameters job.CreateJobParameters) (result job.Information, err error)
40 Get(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result job.Information, err error)
41 GetDebugDataPath(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result job.DataPath, err error)
42 GetStatistics(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result job.Statistics, err error)
43 List(ctx context.Context, accountName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result job.InfoListResultPage, err error)
44 ListComplete(ctx context.Context, accountName string, filter string, top *int32, skip *int32, selectParameter string, orderby string, count *bool) (result job.InfoListResultIterator, err error)
45 }
46
47 var _ ClientAPI = (*job.Client)(nil)
48
View as plain text