stub

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 25, 2020 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewReceiptHandle added in v0.3.0 

func NewReceiptHandle() string

func NewSQSMessageFromFile added in v0.3.0 

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

Types

type AccessLog 

type AccessLog struct {
	Svc        string `json:"svc,omitempty"`
	Method     string `json:"method"`
	Path       string `json:"path"`
	StatusCode int    `json:"status_code"`
	SQSAction  string `json:"sqs_action,omitempty"`
}

func (*AccessLog) String 

func (l *AccessLog) String() string

type StubBigQuery 

type StubBigQuery struct {
	// contains filtered or unexported fields
}

func NewStubBigQuery 

func NewStubBigQuery() *StubBigQuery

func (*StubBigQuery) Close 

func (s *StubBigQuery) Close()

func (*StubBigQuery) Endpoint added in v0.1.0 

func (s *StubBigQuery) Endpoint() string

func (*StubBigQuery) GetLogs 

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

func (*StubBigQuery) LoadedData added in v0.1.2 

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

type StubBigQueryResponseDestinationTable added in v0.1.2 

type StubBigQueryResponseDestinationTable struct {
	ProjectID string `json:"projectId"`
	DatasetID string `json:"datasetId"`
	TableID   string `json:"tableId"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/TableReference?hl=ja

func (*StubBigQueryResponseDestinationTable) String added in v0.1.2 

func (t *StubBigQueryResponseDestinationTable) String() string

type StubBigQueryResponseErrorProto 

type StubBigQueryResponseErrorProto struct {
	Reason    string `json:"reason"`
	Location  string `json:"location"`
	DebugInfo string `json:"debugInfo"`
	Message   string `json:"message"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/ErrorProto?hl=ja

type StubBigQueryResponseJob 

type StubBigQueryResponseJob struct {
	Kind          string                               `json:"kind"`
	Etag          string                               `json:"etag"`
	ID            string                               `json:"id"`
	SelfLink      string                               `json:"selfLink"`
	UserEmail     string                               `json:"user_email"`
	Configuration StubBigQueryResponseJobConfiguration `json:"configuration"`
	JobReference  *StubBigQueryResponseJobReference    `json:"jobReference"`
	Statistics    interface{}                          `json:"statistics"`
	Status        *StubBigQueryResponseJobStatus       `json:"status"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/Job?hl=ja

type StubBigQueryResponseJobConfiguration 

type StubBigQueryResponseJobConfiguration struct {
	JobType      string                                    `json:"jobType"`
	Query        interface{}                               `json:"query,omitempty"`
	Load         *StubBigQueryResponseJobConfigurationLoad `json:"load,omitempty"`
	Copy         interface{}                               `json:"copy,omitempty"`
	Extract      interface{}                               `json:"extract,omitempty"`
	DryRun       bool                                      `json:"dryRun"`
	JobTimeoutMs string                                    `json:"jobTimeoutMs,omitempty"`
	Labels       map[string]string                         `json:"labels,omitempty"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/Job?hl=ja#JobConfiguration

type StubBigQueryResponseJobConfigurationLoad 

type StubBigQueryResponseJobConfigurationLoad struct {
	SourceUris                         []string                              `json:"sourceUris"`
	Schema                             interface{}                           `json:"schema"`
	DestinationTable                   *StubBigQueryResponseDestinationTable `json:"destinationTable"`
	DestinationTableProperties         interface{}                           `json:"destinationTableProperties"`
	CreateDisposition                  string                                `json:"createDisposition"`
	WriteDisposition                   string                                `json:"writeDisposition"`
	NullMarker                         string                                `json:"nullMarker"`
	FieldDelimiter                     string                                `json:"fieldDelimiter"`
	SkipLeadingRows                    int                                   `json:"skipLeadingRows"`
	Encoding                           string                                `json:"encoding"`
	Quote                              string                                `json:"quote"`
	MaxBadRecords                      int                                   `json:"maxBadRecords"`
	SchemaInlineFormat                 string                                `json:"schemaInlineFormat"`
	SchemaInline                       string                                `json:"schemaInline"`
	AllowQuotedNewlines                bool                                  `json:"allowQuotedNewlines"`
	SourceFormat                       string                                `json:"sourceFormat"`
	AllowJaggedRows                    bool                                  `json:"allowJaggedRows"`
	IgnoreUnknownValues                bool                                  `json:"ignoreUnknownValues"`
	ProjectionFields                   []string                              `json:"projectionFields"`
	Autodetect                         bool                                  `json:"autodetect"`
	SchemaUpdateOptions                []string                              `json:"schemaUpdateOptions"`
	TimePartitioning                   interface{}                           `json:"timePartitioning"`
	RangePartitioning                  interface{}                           `json:"rangePartitioning"`
	Clustering                         interface{}                           `json:"clustering"`
	DestinationEncryptionConfiguration interface{}                           `json:"destinationEncryptionConfiguration"`
	UseAvroLogicalTypes                bool                                  `json:"useAvroLogicalTypes"`
	HivePartitioningOptions            interface{}                           `json:"hivePartitioningOptions"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/Job?hl=ja#JobConfigurationLoad

type StubBigQueryResponseJobReference 

type StubBigQueryResponseJobReference struct {
	ProjectID string  `json:"projectId"`
	JobID     string  `json:"jobId"`
	Location  *string `json:"location"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/JobReference?hl=ja

type StubBigQueryResponseJobStatus 

type StubBigQueryResponseJobStatus struct {
	ErrorResult *StubBigQueryResponseErrorProto  `json:"errorResult"`
	Errors      []StubBigQueryResponseErrorProto `json:"errors"`

	//Output only. Running state of the job. Valid states include 'PENDING', 'RUNNING', and 'DONE'.
	State string `json:"state"`
}

as https://cloud.google.com/bigquery/docs/reference/rest/v2/Job?hl=ja#JobStatus

type StubGCS 

type StubGCS struct {
	// contains filtered or unexported fields
}

func NewStubGCS 

func NewStubGCS() *StubGCS

func (*StubGCS) Close 

func (s *StubGCS) Close()

func (*StubGCS) Endpoint added in v0.1.0 

func (s *StubGCS) Endpoint() string

func (*StubGCS) GetLogs 

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

type StubGCSGetBucketResponse 

type StubGCSGetBucketResponse struct {
	Kind         string `json:"kind"`
	ID           string `json:"id"`
	Name         string `json:"name"`
	Location     string `json:"location"`
	LocationType string `json:"locationType"`
}

type StubS3 

type StubS3 struct {
	// contains filtered or unexported fields
}

func NewStubS3 

func NewStubS3(basePath string) *StubS3

func (*StubS3) Close 

func (s *StubS3) Close()

func (*StubS3) Endpoint added in v0.1.0 

func (s *StubS3) Endpoint() string

func (*StubS3) GetLogs 

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

type StubSQS 

type StubSQS struct {
	NumberOfMessagesReceived int
	NumberOfMessagesDeleted  int
	// contains filtered or unexported fields
}

func NewStubSQS 

func NewStubSQS() *StubSQS

func (*StubSQS) ClearMetrix added in v0.3.1 

func (s *StubSQS) ClearMetrix()

func (*StubSQS) Close 

func (s *StubSQS) Close()

func (*StubSQS) Endpoint added in v0.1.0 

func (s *StubSQS) Endpoint() string

func (*StubSQS) GetLogs 

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

func (*StubSQS) SendMessagesFromFile added in v0.3.0 

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

func (*StubSQS) SetRecivedMessages added in v0.1.2 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.