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

plugins

package

Go to main page

Versions in this module

v0

v0.16.6

Jan 10, 2020

v0.16.5

Jan 2, 2020

v0.16.4

Dec 30, 2019

v0.16.3

Dec 19, 2019

v0.16.2

Dec 11, 2019

v0.16.1

Oct 30, 2019

v0.16.0

Oct 9, 2019

v0.15.0

Oct 9, 2019

v0.14.1

Sep 6, 2019

v0.14.0

Sep 4, 2019

v0.1.1

Aug 30, 2019

Changes in this version

type QuboleHiveJob

+ Query *HiveQuery

+ func (m *QuboleHiveJob) GetQuery() *HiveQuery

v0.1.0

Aug 5, 2019

Changes in this version

+ var SparkApplication_Type_name = map[int32]string

+ var SparkApplication_Type_value = map[string]int32

+ type ArrayJob struct

+ MinSuccesses int64

+ Parallelism int64

+ Size int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ArrayJob) Descriptor() ([]byte, []int)

+ func (*ArrayJob) ProtoMessage()

+ func (dst *ArrayJob) XXX_Merge(src proto.Message)

+ func (m *ArrayJob) GetMinSuccesses() int64

+ func (m *ArrayJob) GetParallelism() int64

+ func (m *ArrayJob) GetSize() int64

+ func (m *ArrayJob) Reset()

+ func (m *ArrayJob) String() string

+ func (m *ArrayJob) Validate() error

+ func (m *ArrayJob) XXX_DiscardUnknown()

+ func (m *ArrayJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArrayJob) XXX_Size() int

+ func (m *ArrayJob) XXX_Unmarshal(b []byte) error

+ type ArrayJobValidationError struct

+ func (e ArrayJobValidationError) Cause() error

+ func (e ArrayJobValidationError) Error() string

+ func (e ArrayJobValidationError) ErrorName() string

+ func (e ArrayJobValidationError) Field() string

+ func (e ArrayJobValidationError) Key() bool

+ func (e ArrayJobValidationError) Reason() string

+ type HiveQuery struct

+ Query string

+ RetryCount uint32

+ TimeoutSec uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*HiveQuery) Descriptor() ([]byte, []int)

+ func (*HiveQuery) ProtoMessage()

+ func (dst *HiveQuery) XXX_Merge(src proto.Message)

+ func (m *HiveQuery) GetQuery() string

+ func (m *HiveQuery) GetRetryCount() uint32

+ func (m *HiveQuery) GetTimeoutSec() uint32

+ func (m *HiveQuery) Reset()

+ func (m *HiveQuery) String() string

+ func (m *HiveQuery) Validate() error

+ func (m *HiveQuery) XXX_DiscardUnknown()

+ func (m *HiveQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HiveQuery) XXX_Size() int

+ func (m *HiveQuery) XXX_Unmarshal(b []byte) error

+ type HiveQueryCollection struct

+ Queries []*HiveQuery

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*HiveQueryCollection) Descriptor() ([]byte, []int)

+ func (*HiveQueryCollection) ProtoMessage()

+ func (dst *HiveQueryCollection) XXX_Merge(src proto.Message)

+ func (m *HiveQueryCollection) GetQueries() []*HiveQuery

+ func (m *HiveQueryCollection) Reset()

+ func (m *HiveQueryCollection) String() string

+ func (m *HiveQueryCollection) Validate() error

+ func (m *HiveQueryCollection) XXX_DiscardUnknown()

+ func (m *HiveQueryCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HiveQueryCollection) XXX_Size() int

+ func (m *HiveQueryCollection) XXX_Unmarshal(b []byte) error

+ type HiveQueryCollectionValidationError struct

+ func (e HiveQueryCollectionValidationError) Cause() error

+ func (e HiveQueryCollectionValidationError) Error() string

+ func (e HiveQueryCollectionValidationError) ErrorName() string

+ func (e HiveQueryCollectionValidationError) Field() string

+ func (e HiveQueryCollectionValidationError) Key() bool

+ func (e HiveQueryCollectionValidationError) Reason() string

+ type HiveQueryValidationError struct

+ func (e HiveQueryValidationError) Cause() error

+ func (e HiveQueryValidationError) Error() string

+ func (e HiveQueryValidationError) ErrorName() string

+ func (e HiveQueryValidationError) Field() string

+ func (e HiveQueryValidationError) Key() bool

+ func (e HiveQueryValidationError) Reason() string

+ type QuboleHiveJob struct

+ ClusterLabel string

+ QueryCollection *HiveQueryCollection

+ Tags []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QuboleHiveJob) Descriptor() ([]byte, []int)

+ func (*QuboleHiveJob) ProtoMessage()

+ func (dst *QuboleHiveJob) XXX_Merge(src proto.Message)

+ func (m *QuboleHiveJob) GetClusterLabel() string

+ func (m *QuboleHiveJob) GetQueryCollection() *HiveQueryCollection

+ func (m *QuboleHiveJob) GetTags() []string

+ func (m *QuboleHiveJob) Reset()

+ func (m *QuboleHiveJob) String() string

+ func (m *QuboleHiveJob) Validate() error

+ func (m *QuboleHiveJob) XXX_DiscardUnknown()

+ func (m *QuboleHiveJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QuboleHiveJob) XXX_Size() int

+ func (m *QuboleHiveJob) XXX_Unmarshal(b []byte) error

+ type QuboleHiveJobValidationError struct

+ func (e QuboleHiveJobValidationError) Cause() error

+ func (e QuboleHiveJobValidationError) Error() string

+ func (e QuboleHiveJobValidationError) ErrorName() string

+ func (e QuboleHiveJobValidationError) Field() string

+ func (e QuboleHiveJobValidationError) Key() bool

+ func (e QuboleHiveJobValidationError) Reason() string

+ type SidecarJob struct

+ PodSpec *v1.PodSpec

+ PrimaryContainerName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SidecarJob) Descriptor() ([]byte, []int)

+ func (*SidecarJob) ProtoMessage()

+ func (dst *SidecarJob) XXX_Merge(src proto.Message)

+ func (m *SidecarJob) GetPodSpec() *v1.PodSpec

+ func (m *SidecarJob) GetPrimaryContainerName() string

+ func (m *SidecarJob) Reset()

+ func (m *SidecarJob) String() string

+ func (m *SidecarJob) Validate() error

+ func (m *SidecarJob) XXX_DiscardUnknown()

+ func (m *SidecarJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SidecarJob) XXX_Size() int

+ func (m *SidecarJob) XXX_Unmarshal(b []byte) error

+ type SidecarJobValidationError struct

+ func (e SidecarJobValidationError) Cause() error

+ func (e SidecarJobValidationError) Error() string

+ func (e SidecarJobValidationError) ErrorName() string

+ func (e SidecarJobValidationError) Field() string

+ func (e SidecarJobValidationError) Key() bool

+ func (e SidecarJobValidationError) Reason() string

+ type SparkApplication struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SparkApplication) Descriptor() ([]byte, []int)

+ func (*SparkApplication) ProtoMessage()

+ func (dst *SparkApplication) XXX_Merge(src proto.Message)

+ func (m *SparkApplication) Reset()

+ func (m *SparkApplication) String() string

+ func (m *SparkApplication) Validate() error

+ func (m *SparkApplication) XXX_DiscardUnknown()

+ func (m *SparkApplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SparkApplication) XXX_Size() int

+ func (m *SparkApplication) XXX_Unmarshal(b []byte) error

+ type SparkApplicationValidationError struct

+ func (e SparkApplicationValidationError) Cause() error

+ func (e SparkApplicationValidationError) Error() string

+ func (e SparkApplicationValidationError) ErrorName() string

+ func (e SparkApplicationValidationError) Field() string

+ func (e SparkApplicationValidationError) Key() bool

+ func (e SparkApplicationValidationError) Reason() string

+ type SparkApplication_Type int32

+ const SparkApplication_JAVA

+ const SparkApplication_PYTHON

+ const SparkApplication_R

+ const SparkApplication_SCALA

+ func (SparkApplication_Type) EnumDescriptor() ([]byte, []int)

+ func (x SparkApplication_Type) String() string

+ type SparkJob struct

+ ApplicationType SparkApplication_Type

+ ExecutorPath string

+ HadoopConf map[string]string

+ MainApplicationFile string

+ MainClass string

+ SparkConf map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SparkJob) Descriptor() ([]byte, []int)

+ func (*SparkJob) ProtoMessage()

+ func (dst *SparkJob) XXX_Merge(src proto.Message)

+ func (m *SparkJob) GetApplicationType() SparkApplication_Type

+ func (m *SparkJob) GetExecutorPath() string

+ func (m *SparkJob) GetHadoopConf() map[string]string

+ func (m *SparkJob) GetMainApplicationFile() string

+ func (m *SparkJob) GetMainClass() string

+ func (m *SparkJob) GetSparkConf() map[string]string

+ func (m *SparkJob) Reset()

+ func (m *SparkJob) String() string

+ func (m *SparkJob) Validate() error

+ func (m *SparkJob) XXX_DiscardUnknown()

+ func (m *SparkJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SparkJob) XXX_Size() int

+ func (m *SparkJob) XXX_Unmarshal(b []byte) error

+ type SparkJobValidationError struct

+ func (e SparkJobValidationError) Cause() error

+ func (e SparkJobValidationError) Error() string

+ func (e SparkJobValidationError) ErrorName() string

+ func (e SparkJobValidationError) Field() string

+ func (e SparkJobValidationError) Key() bool

+ func (e SparkJobValidationError) Reason() string

+ type Waitable struct

+ Phase core.WorkflowExecution_Phase

+ WfExecId *core.WorkflowExecutionIdentifier

+ WorkflowId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Waitable) Descriptor() ([]byte, []int)

+ func (*Waitable) ProtoMessage()

+ func (dst *Waitable) XXX_Merge(src proto.Message)

+ func (m *Waitable) GetPhase() core.WorkflowExecution_Phase

+ func (m *Waitable) GetWfExecId() *core.WorkflowExecutionIdentifier

+ func (m *Waitable) GetWorkflowId() string

+ func (m *Waitable) Reset()

+ func (m *Waitable) String() string

+ func (m *Waitable) Validate() error

+ func (m *Waitable) XXX_DiscardUnknown()

+ func (m *Waitable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Waitable) XXX_Size() int

+ func (m *Waitable) XXX_Unmarshal(b []byte) error

+ type WaitableValidationError struct

+ func (e WaitableValidationError) Cause() error

+ func (e WaitableValidationError) Error() string

+ func (e WaitableValidationError) ErrorName() string

+ func (e WaitableValidationError) Field() string

+ func (e WaitableValidationError) Key() bool

+ func (e WaitableValidationError) Reason() string