stub

package

Go to main page

Versions in this module

v0

v0.3.1

Jun 25, 2020

Changes in this version

type StubSQS

+ NumberOfMessagesDeleted int

+ NumberOfMessagesReceived int

+ func (s *StubSQS) ClearMetrix()

v0.3.0

Mar 30, 2020

Changes in this version

+ func NewReceiptHandle() string

+ func NewSQSMessageFromFile(path string) (*sqs.Message, error)

type StubSQS

+ func (s *StubSQS) SendMessagesFromFile(paths []string) error

v0.2.1

Mar 10, 2020

v0.2.0

Mar 10, 2020

v0.1.3

Feb 13, 2020

v0.1.2

Feb 10, 2020

Changes in this version

+ type Manager struct

+ BigQuery *StubBigQuery

+ CloudStorage *StubGCS

+ S3 *StubS3

+ SQS *StubSQS

+ func NewManager(basePath string) *Manager

+ func (m *Manager) Close()

+ func (m *Manager) OverwriteConfig(org *cloud.Config)

type StubBigQuery

+ func (s *StubBigQuery) LoadedData() map[string][]string

+ type StubBigQueryResponseDestinationTable struct

+ DatasetID string

+ ProjectID string

+ TableID string

+ func (t *StubBigQueryResponseDestinationTable) String() string

type StubSQS

+ func (s *StubSQS) SetRecivedMessages(msgs []*sqs.Message)

v0.1.1

Feb 10, 2020

v0.1.0

Feb 10, 2020

Changes in this version

type StubBigQuery

+ func (s *StubBigQuery) Endpoint() string

type StubGCS

+ func (s *StubGCS) Endpoint() string

type StubS3

+ func (s *StubS3) Endpoint() string

type StubSQS

+ func (s *StubSQS) Endpoint() string

v0.0.0

Feb 7, 2020

Changes in this version

+ type AccessLog struct

+ Method string

+ Path string

+ SQSAction string

+ StatusCode int

+ Svc string

+ func (l *AccessLog) String() string

+ type StubBigQuery struct

+ func NewStubBigQuery() *StubBigQuery

+ func (s *StubBigQuery) Close()

+ func (s *StubBigQuery) GetLogs() []string

+ func (s *StubBigQuery) NewClient(projectID string) (*bigquery.Client, error)

+ type StubBigQueryResponseErrorProto struct

+ DebugInfo string

+ Location string

+ Message string

+ Reason string

+ type StubBigQueryResponseJob struct

+ Configuration StubBigQueryResponseJobConfiguration

+ Etag string

+ ID string

+ JobReference *StubBigQueryResponseJobReference

+ Kind string

+ SelfLink string

+ Statistics interface{}

+ Status *StubBigQueryResponseJobStatus

+ UserEmail string

+ type StubBigQueryResponseJobConfiguration struct

+ Copy interface{}

+ DryRun bool

+ Extract interface{}

+ JobTimeoutMs string

+ JobType string

+ Labels map[string]string

+ Load *StubBigQueryResponseJobConfigurationLoad

+ Query interface{}

+ type StubBigQueryResponseJobConfigurationLoad struct

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ Autodetect bool

+ Clustering interface{}

+ CreateDisposition string

+ DestinationEncryptionConfiguration interface{}

+ DestinationTable interface{}

+ DestinationTableProperties interface{}

+ Encoding string

+ FieldDelimiter string

+ HivePartitioningOptions interface{}

+ IgnoreUnknownValues bool

+ MaxBadRecords int

+ NullMarker string

+ ProjectionFields []string

+ Quote string

+ RangePartitioning interface{}

+ Schema interface{}

+ SchemaInline string

+ SchemaInlineFormat string

+ SchemaUpdateOptions []string

+ SkipLeadingRows int

+ SourceFormat string

+ SourceUris []string

+ TimePartitioning interface{}

+ UseAvroLogicalTypes bool

+ WriteDisposition string

+ type StubBigQueryResponseJobReference struct

+ JobID string

+ Location *string

+ ProjectID string

+ type StubBigQueryResponseJobStatus struct

+ ErrorResult *StubBigQueryResponseErrorProto

+ Errors []StubBigQueryResponseErrorProto

+ State string

+ type StubGCS struct

+ func NewStubGCS() *StubGCS

+ func (s *StubGCS) Close()

+ func (s *StubGCS) GetLogs() []string

+ func (s *StubGCS) NewClient() (*storage.Client, error)

+ type StubGCSGetBucketResponse struct

+ ID string

+ Kind string

+ Location string

+ LocationType string

+ Name string

+ type StubS3 struct

+ func NewStubS3(basePath string) *StubS3

+ func (s *StubS3) Close()

+ func (s *StubS3) GetLogs() []string

+ func (s *StubS3) NewSvc() *s3.S3

+ type StubSQS struct

+ func NewStubSQS(receiptHandle string) *StubSQS

+ func (s *StubSQS) Close()

+ func (s *StubSQS) GetLogs() []string

+ func (s *StubSQS) NewSvc() *sqs.SQS

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL