Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 12, 2019

v0.1.3

Jul 17, 2019

Changes in this version

+ const DefaultRetries

+ const GlobalFailure

+ const JSONUnmarshalError

+ const NoRetries

+ func GetNonRetryableError(err error, method FlinkMethod, errorCode string, message ...string) error

+ func GetRetryableError(err error, method FlinkMethod, errorCode string, maxRetries int32, ...) error

+ type FlinkApplicationError struct

+ AppError string

+ ErrorCode string

+ IsFailFast bool

+ IsRetryable bool

+ LastErrorUpdateTime *metav1.Time

+ MaxRetries int32

+ Method FlinkMethod

+ func NewFlinkApplicationError(appError string, method FlinkMethod, errorCode string, isRetryable bool, ...) *FlinkApplicationError

+ func (f *FlinkApplicationError) DeepCopy() *FlinkApplicationError

+ func (f *FlinkApplicationError) DeepCopyInto(out *FlinkApplicationError)

+ func (f *FlinkApplicationError) Error() string

+ type FlinkMethod string

+ const CancelJobWithSavepoint

+ const CheckSavepointStatus

+ const ForceCancelJob

+ const GetCheckpointCounts

+ const GetClusterOverview

+ const GetJobConfig

+ const GetJobOverview

+ const GetJobs

+ const GetLatestCheckpoint

+ const GetTaskManagers

+ const SubmitJob

+ type RetryHandler struct

+ func NewRetryHandler(baseBackoff time.Duration, timeToWait time.Duration, maxBackOff time.Duration) RetryHandler

+ func (r RetryHandler) GetRetryDelay(retryCount int32) time.Duration

+ func (r RetryHandler) IsErrorRetryable(err error) bool

+ func (r RetryHandler) IsRetryRemaining(err error, retryCount int32) bool

+ func (r RetryHandler) IsTimeToRetry(clock clock.Clock, lastUpdatedTime time.Time, retryCount int32) bool

+ func (r RetryHandler) WaitOnError(clock clock.Clock, lastUpdatedTime time.Time) (time.Duration, bool)

+ type RetryHandlerInterface interface

+ GetRetryDelay func(retryCount int32) time.Duration

+ IsErrorRetryable func(err error) bool

+ IsRetryRemaining func(err error, retryCount int32) bool

+ IsTimeToRetry func(clock clock.Clock, lastUpdatedTime time.Time, retryCount int32) bool

+ WaitOnError func(clock clock.Clock, lastUpdatedTime time.Time) (time.Duration, bool)

type SubmitJobRequest

+ AllowNonRestoredState bool

v0.1.2

Jun 24, 2019

v0.1.1

May 31, 2019

Changes in this version

+ type CancelJobRequest struct

+ CancelJob bool

+ TargetDirectory string

+ type CancelJobResponse struct

+ TriggerID string

+ type CheckpointResponse struct

+ Counts map[string]int32

+ History []CheckpointStatistics

+ Latest LatestCheckpoints

+ type CheckpointStatistics struct

+ AlignmentBuffered int64

+ Discarded bool

+ EndToEndDuration int64

+ ExternalPath string

+ FailureMessage string

+ FailureTimestamp int64

+ ID uint

+ IsSavepoint bool

+ LatestAckTimestamp int64

+ NumSubtasks int64

+ RestoredTimeStamp int64

+ StateSize int64

+ Status CheckpointStatus

+ TriggerTimestamp int64

+ type CheckpointStatus string

+ const CheckpointCompleted

+ const CheckpointFailed

+ const CheckpointInProgress

+ type ClusterOverviewResponse struct

+ NumberOfTaskSlots int32

+ SlotsAvailable int32

+ TaskManagerCount int32

+ type FailureCause struct

+ Class string

+ StackTrace string

+ type FlinkAPIInterface interface

+ CancelJobWithSavepoint func(ctx context.Context, url string, jobID string) (string, error)

+ CheckSavepointStatus func(ctx context.Context, url string, jobID, triggerID string) (*SavepointResponse, error)

+ ForceCancelJob func(ctx context.Context, url string, jobID string) error

+ GetCheckpointCounts func(ctx context.Context, url string, jobID string) (*CheckpointResponse, error)

+ GetClusterOverview func(ctx context.Context, url string) (*ClusterOverviewResponse, error)

+ GetJobConfig func(ctx context.Context, url string, jobID string) (*JobConfigResponse, error)

+ GetJobOverview func(ctx context.Context, url string, jobID string) (*FlinkJobOverview, error)

+ GetJobs func(ctx context.Context, url string) (*GetJobsResponse, error)

+ GetLatestCheckpoint func(ctx context.Context, url string, jobID string) (*CheckpointStatistics, error)

+ GetTaskManagers func(ctx context.Context, url string) (*TaskManagersResponse, error)

+ SubmitJob func(ctx context.Context, url string, jarID string, ...) (*SubmitJobResponse, error)

+ func NewFlinkJobManagerClient(config config.RuntimeConfig) FlinkAPIInterface

+ type FlinkJob struct

+ JobID string

+ Status JobState

+ type FlinkJobManagerClient struct

+ func (c *FlinkJobManagerClient) CancelJobWithSavepoint(ctx context.Context, url string, jobID string) (string, error)

+ func (c *FlinkJobManagerClient) CheckSavepointStatus(ctx context.Context, url string, jobID, triggerID string) (*SavepointResponse, error)

+ func (c *FlinkJobManagerClient) ForceCancelJob(ctx context.Context, url string, jobID string) error

+ func (c *FlinkJobManagerClient) GetCheckpointCounts(ctx context.Context, url string, jobID string) (*CheckpointResponse, error)

+ func (c *FlinkJobManagerClient) GetClusterOverview(ctx context.Context, url string) (*ClusterOverviewResponse, error)

+ func (c *FlinkJobManagerClient) GetJobConfig(ctx context.Context, url, jobID string) (*JobConfigResponse, error)

+ func (c *FlinkJobManagerClient) GetJobOverview(ctx context.Context, url string, jobID string) (*FlinkJobOverview, error)

+ func (c *FlinkJobManagerClient) GetJobs(ctx context.Context, url string) (*GetJobsResponse, error)

+ func (c *FlinkJobManagerClient) GetLatestCheckpoint(ctx context.Context, url string, jobID string) (*CheckpointStatistics, error)

+ func (c *FlinkJobManagerClient) GetTaskManagers(ctx context.Context, url string) (*TaskManagersResponse, error)

+ func (c *FlinkJobManagerClient) SubmitJob(ctx context.Context, url string, jarID string, ...) (*SubmitJobResponse, error)

+ type FlinkJobOverview struct

+ EndTime int64

+ JobID string

+ StartTime int64

+ State JobState

+ type GetJobsResponse struct

+ Jobs []FlinkJob

+ type JobConfigResponse struct

+ ExecutionConfig JobExecutionConfig

+ JobID string

+ type JobExecutionConfig struct

+ Parallelism int32

+ type JobState string

+ const Canceled

+ const Cancelling

+ const Created

+ const Failed

+ const Failing

+ const Finished

+ const Reconciling

+ const Restarting

+ const Running

+ const Suspended

+ type LatestCheckpoints struct

+ Completed *CheckpointStatistics

+ Failed *CheckpointStatistics

+ Restored *CheckpointStatistics

+ Savepoint *CheckpointStatistics

+ type SavepointOperationResponse struct

+ FailureCause FailureCause

+ Location string

+ type SavepointResponse struct

+ Operation SavepointOperationResponse

+ SavepointStatus SavepointStatusResponse

+ type SavepointStatus string

+ const SavePointCompleted

+ const SavePointInProgress

+ const SavePointInvalid

+ type SavepointStatusResponse struct

+ Status SavepointStatus

+ type SubmitJobRequest struct

+ EntryClass string

+ Parallelism int32

+ ProgramArgs string

+ SavepointPath string

+ type SubmitJobResponse struct

+ JobID string

+ type TaskManagerStats struct

+ DataPort int32

+ FreeSlots int32

+ Path string

+ SlotsNumber int32

+ TimeSinceLastHeartbeat int64

+ type TaskManagersResponse struct

+ TaskManagers []TaskManagerStats