bigquery

Documentation

Index

• Variables
• func NewLoaderContext(ctx context.Context, bqWatcher *watcher.Watcher[*BigQueryDataset]) context.Context
• func NewWatcher(ctx context.Context, mgr *watcher.Manager) *watcher.Watcher[*BigQueryDataset]
• func Search(ctx context.Context, q string) ([]*search.Result, error)
• type BigQueryDataset
  • func Get(ctx context.Context, teamSlug slug.Slug, environment, name string) (*BigQueryDataset, error)
  • func GetByIdent(ctx context.Context, id ident.Ident) (*BigQueryDataset, error)
  • func ListAllForTeam(ctx context.Context, teamSlug slug.Slug) []*BigQueryDataset
  • func (b *BigQueryDataset) DeepCopyObject() runtime.Object
  • func (b *BigQueryDataset) GetLabels() map[string]string
  • func (b *BigQueryDataset) GetName() string
  • func (b *BigQueryDataset) GetNamespace() string
  • func (b *BigQueryDataset) GetObjectKind() schema.ObjectKind
  • func (b BigQueryDataset) ID() ident.Ident
  • func (BigQueryDataset) IsNode()
  • func (BigQueryDataset) IsPersistence()
  • func (BigQueryDataset) IsSearchNode()
• type BigQueryDatasetAccess
• type BigQueryDatasetAccessConnection
• type BigQueryDatasetAccessEdge
• type BigQueryDatasetAccessOrder
• type BigQueryDatasetAccessOrderField
  • func (e BigQueryDatasetAccessOrderField) IsValid() bool
  • func (e BigQueryDatasetAccessOrderField) MarshalGQL(w io.Writer)
  • func (e BigQueryDatasetAccessOrderField) String() string
  • func (e *BigQueryDatasetAccessOrderField) UnmarshalGQL(v interface{}) error
• type BigQueryDatasetConnection
  • func ListForTeam(ctx context.Context, teamSlug slug.Slug, page *pagination.Pagination, ...) (*BigQueryDatasetConnection, error)
  • func ListForWorkload(ctx context.Context, teamSlug slug.Slug, ...) (*BigQueryDatasetConnection, error)
• type BigQueryDatasetEdge
• type BigQueryDatasetOrder
• type BigQueryDatasetOrderField
  • func (e BigQueryDatasetOrderField) IsValid() bool
  • func (e BigQueryDatasetOrderField) MarshalGQL(w io.Writer)
  • func (e BigQueryDatasetOrderField) String() string
  • func (e *BigQueryDatasetOrderField) UnmarshalGQL(v interface{}) error
• type BigQueryDatasetStatus
• type TeamInventoryCountBigQueryDatasets

Variables

var (
	SortFilter       = sortfilter.New[*BigQueryDataset, BigQueryDatasetOrderField, struct{}](BigQueryDatasetOrderFieldName)
	SortFilterAccess = sortfilter.New[*BigQueryDatasetAccess, BigQueryDatasetAccessOrderField, struct{}](BigQueryDatasetAccessOrderFieldEmail)
)

Functions

func NewLoaderContext

func NewLoaderContext(ctx context.Context, bqWatcher *watcher.Watcher[*BigQueryDataset]) context.Context

func NewWatcher

func NewWatcher(ctx context.Context, mgr *watcher.Manager) *watcher.Watcher[*BigQueryDataset]

func Search

func Search(ctx context.Context, q string) ([]*search.Result, error)

Types

type BigQueryDataset

type BigQueryDataset struct {
	// Name equals to the Instance name, not the kubernetes resource name
	Name              string                   `json:"name"`
	Description       *string                  `json:"description,omitempty"`
	CascadingDelete   bool                     `json:"cascadingDelete"`
	Location          string                   `json:"location"`
	Status            *BigQueryDatasetStatus   `json:"status"`
	Access            []*BigQueryDatasetAccess `json:"-"`
	TeamSlug          slug.Slug                `json:"-"`
	EnvironmentName   string                   `json:"-"`
	WorkloadReference *workload.Reference      `json:"-"`
	ProjectID         string                   `json:"-"`
	K8sResourceName   string                   `json:"-"`
}

func Get

func Get(ctx context.Context, teamSlug slug.Slug, environment, name string) (*BigQueryDataset, error)

func GetByIdent

func GetByIdent(ctx context.Context, id ident.Ident) (*BigQueryDataset, error)

func ListAllForTeam

func ListAllForTeam(ctx context.Context, teamSlug slug.Slug) []*BigQueryDataset

func (*BigQueryDataset) DeepCopyObject

func (b *BigQueryDataset) DeepCopyObject() runtime.Object

func (*BigQueryDataset) GetLabels

func (b *BigQueryDataset) GetLabels() map[string]string

func (*BigQueryDataset) GetName

func (b *BigQueryDataset) GetName() string

func (*BigQueryDataset) GetNamespace

func (b *BigQueryDataset) GetNamespace() string

func (*BigQueryDataset) GetObjectKind

func (b *BigQueryDataset) GetObjectKind() schema.ObjectKind

func (BigQueryDataset) ID

func (b BigQueryDataset) ID() ident.Ident

func (BigQueryDataset) IsNode

func (BigQueryDataset) IsNode()

func (BigQueryDataset) IsPersistence

func (BigQueryDataset) IsPersistence()

func (BigQueryDataset) IsSearchNode

func (BigQueryDataset) IsSearchNode()

type BigQueryDatasetAccess

type BigQueryDatasetAccess struct {
	Role  string `json:"role"`
	Email string `json:"email"`
}

type BigQueryDatasetAccessConnection

type BigQueryDatasetAccessConnection = pagination.Connection[*BigQueryDatasetAccess]

type BigQueryDatasetAccessEdge

type BigQueryDatasetAccessEdge = pagination.Edge[*BigQueryDatasetAccess]

type BigQueryDatasetAccessOrder

type BigQueryDatasetAccessOrder struct {
	Field     BigQueryDatasetAccessOrderField `json:"field"`
	Direction model.OrderDirection            `json:"direction"`
}

type BigQueryDatasetAccessOrderField

type BigQueryDatasetAccessOrderField string

const (
	BigQueryDatasetAccessOrderFieldRole  BigQueryDatasetAccessOrderField = "ROLE"
	BigQueryDatasetAccessOrderFieldEmail BigQueryDatasetAccessOrderField = "EMAIL"
)

func (BigQueryDatasetAccessOrderField) IsValid

func (e BigQueryDatasetAccessOrderField) IsValid() bool

func (BigQueryDatasetAccessOrderField) MarshalGQL

func (e BigQueryDatasetAccessOrderField) MarshalGQL(w io.Writer)

func (BigQueryDatasetAccessOrderField) String

func (e BigQueryDatasetAccessOrderField) String() string

func (*BigQueryDatasetAccessOrderField) UnmarshalGQL

func (e *BigQueryDatasetAccessOrderField) UnmarshalGQL(v interface{}) error

type BigQueryDatasetConnection

type BigQueryDatasetConnection = pagination.Connection[*BigQueryDataset]

func ListForTeam

func ListForTeam(ctx context.Context, teamSlug slug.Slug, page *pagination.Pagination, orderBy *BigQueryDatasetOrder) (*BigQueryDatasetConnection, error)

func ListForWorkload

func ListForWorkload(ctx context.Context, teamSlug slug.Slug, datasets []nais_io_v1.CloudBigQueryDataset, orderBy *BigQueryDatasetOrder) (*BigQueryDatasetConnection, error)

type BigQueryDatasetEdge

type BigQueryDatasetEdge = pagination.Edge[*BigQueryDataset]

type BigQueryDatasetOrder

type BigQueryDatasetOrder struct {
	Field     BigQueryDatasetOrderField `json:"field"`
	Direction model.OrderDirection      `json:"direction"`
}

type BigQueryDatasetOrderField

type BigQueryDatasetOrderField string

const (
	BigQueryDatasetOrderFieldName        BigQueryDatasetOrderField = "NAME"
	BigQueryDatasetOrderFieldEnvironment BigQueryDatasetOrderField = "ENVIRONMENT"
)

func (BigQueryDatasetOrderField) IsValid

func (e BigQueryDatasetOrderField) IsValid() bool

func (BigQueryDatasetOrderField) MarshalGQL

func (e BigQueryDatasetOrderField) MarshalGQL(w io.Writer)

func (BigQueryDatasetOrderField) String

func (e BigQueryDatasetOrderField) String() string

func (*BigQueryDatasetOrderField) UnmarshalGQL

func (e *BigQueryDatasetOrderField) UnmarshalGQL(v interface{}) error

type BigQueryDatasetStatus

type BigQueryDatasetStatus struct {
	CreationTime     time.Time          `json:"creationTime"`
	LastModifiedTime *time.Time         `json:"lastModifiedTime,omitempty"`
	Conditions       []metav1.Condition `json:"-"`
}

type TeamInventoryCountBigQueryDatasets

type TeamInventoryCountBigQueryDatasets struct {
	Total int
}