influxdb

Documentation

Index

• func DefaultAuthorization(src *platform.Source) influx.Authorizer
• type BucketService
  • func (s *BucketService) CreateBucket(ctx context.Context, b *platform.Bucket) error
  • func (s *BucketService) DeleteBucket(ctx context.Context, id platform.ID) error
  • func (s *BucketService) FindBucket(ctx context.Context, filter platform.BucketFilter) (*platform.Bucket, error)
  • func (s *BucketService) FindBucketByID(ctx context.Context, id platform.ID) (*platform.Bucket, error)
  • func (s *BucketService) FindBucketByName(ctx context.Context, orgID platform.ID, n string) (*platform.Bucket, error)
  • func (s *BucketService) FindBuckets(ctx context.Context, filter platform.BucketFilter, opt ...platform.FindOptions) ([]*platform.Bucket, int, error)
  • func (s *BucketService) UpdateBucket(ctx context.Context, id platform.ID, upd platform.BucketUpdate) (*platform.Bucket, error)
• type SourceProxyQueryService
  • func (s *SourceProxyQueryService) Check(context.Context) check.Response
  • func (s *SourceProxyQueryService) Query(ctx context.Context, w io.Writer, req *query.ProxyRequest) (flux.Statistics, error)

Functions

func DefaultAuthorization

func DefaultAuthorization(src *platform.Source) influx.Authorizer

DefaultAuthorization creates either a shared JWT builder, basic auth or Noop This is copy of the method from chronograf/influx adapted for platform sources.

Types

type BucketService

type BucketService struct {
	Source *platform.Source
}

BucketService connects to Influx via HTTP using tokens to manage buckets

func (*BucketService) CreateBucket

func (s *BucketService) CreateBucket(ctx context.Context, b *platform.Bucket) error

func (*BucketService) DeleteBucket

func (s *BucketService) DeleteBucket(ctx context.Context, id platform.ID) error

func (*BucketService) FindBucket

func (s *BucketService) FindBucket(ctx context.Context, filter platform.BucketFilter) (*platform.Bucket, error)

func (*BucketService) FindBucketByID

func (s *BucketService) FindBucketByID(ctx context.Context, id platform.ID) (*platform.Bucket, error)

func (*BucketService) FindBucketByName

func (s *BucketService) FindBucketByName(ctx context.Context, orgID platform.ID, n string) (*platform.Bucket, error)

func (*BucketService) FindBuckets

func (s *BucketService) FindBuckets(ctx context.Context, filter platform.BucketFilter, opt ...platform.FindOptions) ([]*platform.Bucket, int, error)

func (*BucketService) UpdateBucket

func (s *BucketService) UpdateBucket(ctx context.Context, id platform.ID, upd platform.BucketUpdate) (*platform.Bucket, error)

type SourceProxyQueryService

type SourceProxyQueryService struct {
	InsecureSkipVerify bool
	URL                string
	OrganizationID     platform.ID
	platform.SourceFields
	platform.V1SourceFields
}

func (*SourceProxyQueryService) Check

func (s *SourceProxyQueryService) Check(context.Context) check.Response

func (*SourceProxyQueryService) Query

func (s *SourceProxyQueryService) Query(ctx context.Context, w io.Writer, req *query.ProxyRequest) (flux.Statistics, error)