interfaces

Documentation

Index

• type BigQueryClient
• type BigQueryIterator
• type CacheService
• type CloudStorageClient
• type NotifyService
• type PolicyClient
• type PubSubClient

Types

type BigQueryClient

type BigQueryClient interface {
	Query(ctx context.Context, query string) (BigQueryIterator, *bigquery.JobStatistics, error)
}

type BigQueryIterator

type BigQueryIterator interface {
	Next(dst interface{}) error
}

type CacheService

type CacheService interface {
	NewWriter(ctx context.Context, ID model.QueryID) (io.WriteCloser, error)
	NewReader(ctx context.Context, ID model.QueryID) (io.ReadCloser, error)
	String() string
}

type CloudStorageClient

type CloudStorageClient interface {
	PutObject(ctx context.Context, bucketName, objectName string) (io.WriteCloser, error)
	GetObject(ctx context.Context, bucketName, objectName string) (io.ReadCloser, error)
}

type NotifyService

type NotifyService interface {
	Publish(ctx context.Context, alert model.Alert) error
}

type PolicyClient

type PolicyClient interface {
	Query(ctx context.Context, query string, input, output any, options ...opac.QueryOption) error
	Metadata() ast.FlatAnnotationsRefSet
}

type PubSubClient

type PubSubClient interface {
	Publish(ctx context.Context, topic string, data []byte) error
}