types

Documentation

Index

• Constants
• Variables
• type BQDatasetID
  • func (x BQDatasetID) String() string
• type BQPartition
  • func (x BQPartition) Type() bigquery.TimePartitioningType
• type BQTableID
  • func (x BQTableID) String() string
• type CSBucket
  • func (x CSBucket) String() string
• type CSObjectID
  • func (x CSObjectID) String() string
• type CSUrl
  • func (x CSUrl) Parse() (CSBucket, CSObjectID, error)
  • func (x CSUrl) String() string
• type EventSchema
  • func (x EventSchema) Query() string
• type GoogleProjectID
  • func (x GoogleProjectID) String() string
• type IngestID
  • func NewIngestID() IngestID
• type LogID
  • func NewLogID(data any) (LogID, error)
• type MsgState
• type MsgType
• type ObjectCompress
• type ObjectParser
• type ObjectSchema
  • func (x ObjectSchema) Query() string
• type ObjectType
• type ObjectURL
  • func (x ObjectURL) ParseAsCloudStorage() (CSBucket, CSObjectID, error)
  • func (x ObjectURL) Type() ObjectType
• type PubSubMessageID
• type PubSubTopicID
  • func (x PubSubTopicID) String() string
• type RequestID
  • func NewRequestID() RequestID
  • func (x RequestID) Empty() bool
  • func (x RequestID) String() string

Constants

const (
	MsgPubSub MsgType = "pubsub"

	MsgFailed    MsgState = "failed"
	MsgRunning   MsgState = "running"
	MsgCompleted MsgState = "completed"
)

Variables

var (
	ErrInvalidOption = goerr.New("invalid option")

	// Bad request
	ErrUnauthorized   = goerr.New("unauthorized")
	ErrInvalidRequest = goerr.New("invalid request")

	// Configuration error
	ErrNoSourceMatched = goerr.New("no source matched")
	ErrNoPolicyData    = goerr.New("no policy data")

	// Runtime error
	ErrDataInsertion       = goerr.New("failed to insert data to bigquery")
	ErrNoPolicyResult      = goerr.New("no policy result")
	ErrInvalidPolicyResult = goerr.New("invalid policy result")
	ErrStateNotFound       = goerr.New("state not found")
	ErrTableNotFound       = goerr.New("table not found")

	// Assertion error
	ErrAssertion = goerr.New("assertion error")

	// Normal error
	ErrBlockingPubSub   = goerr.New("blocking pubsub ack")
	ErrSchemaNotMatched = goerr.New("schema not matched")
)

var (
	AppVersion = "(none)"
)

Types

type BQDatasetID

type BQDatasetID string

func (BQDatasetID) String

func (x BQDatasetID) String() string

type BQPartition

type BQPartition string

const (
	BQPartitionNone  BQPartition = ""
	BQPartitionHour  BQPartition = "hour"
	BQPartitionDay   BQPartition = "day"
	BQPartitionMonth BQPartition = "month"
	BQPartitionYear  BQPartition = "year"
)

func (BQPartition) Type

func (x BQPartition) Type() bigquery.TimePartitioningType

type BQTableID

type BQTableID string

func (BQTableID) String

func (x BQTableID) String() string

type CSBucket

type CSBucket string

func (CSBucket) String

func (x CSBucket) String() string

type CSObjectID

type CSObjectID string

func (CSObjectID) String

func (x CSObjectID) String() string

type CSUrl

type CSUrl string

func (CSUrl) Parse

func (x CSUrl) Parse() (CSBucket, CSObjectID, error)

func (CSUrl) String

func (x CSUrl) String() string

type EventSchema

type EventSchema string

EventSchema presents schema of event data that is received from HTTP request.

const (
	CloudStorageEventSchema EventSchema = "cs"
	SwarmEventSchema        EventSchema = "swarm"
)

func (EventSchema) Query

func (x EventSchema) Query() string

type GoogleProjectID

type GoogleProjectID string

Google Cloud Platform

func (GoogleProjectID) String

func (x GoogleProjectID) String() string

type IngestID

type IngestID string

Ingestion metadata

func NewIngestID

func NewIngestID() IngestID

type LogID

type LogID string

func NewLogID

func NewLogID(data any) (LogID, error)

type MsgState

type MsgState string

type MsgType

type MsgType string

type ObjectCompress

type ObjectCompress string

const (
	NoCompress ObjectCompress = ""
	GZIPComp   ObjectCompress = "gzip"
)

type ObjectParser

type ObjectParser string

Object information

const (
	JSONParser ObjectParser = "json"
)

type ObjectSchema

type ObjectSchema string

func (ObjectSchema) Query

func (x ObjectSchema) Query() string

type ObjectType

type ObjectType string

const (
	UnknownObject      ObjectType = ""
	CloudStorageObject ObjectType = "cs"
)

type ObjectURL

type ObjectURL string

func (ObjectURL) ParseAsCloudStorage

func (x ObjectURL) ParseAsCloudStorage() (CSBucket, CSObjectID, error)

func (ObjectURL) Type

func (x ObjectURL) Type() ObjectType

type PubSubMessageID

type PubSubMessageID string

type PubSubTopicID

type PubSubTopicID string

func (PubSubTopicID) String

func (x PubSubTopicID) String() string

type RequestID

type RequestID string

RequestID is a unique identifier for each request

func NewRequestID

func NewRequestID() RequestID

func (RequestID) Empty

func (x RequestID) Empty() bool

func (RequestID) String

func (x RequestID) String() string