Versions in this module Expand all Collapse all v1 v1.5.0 Aug 14, 2020 Changes in this version + func DefaultDialect() *domain.Dialect + func NewWriteAPIBlocking(org string, bucket string, service http2.Service, writeOptions *write.Options) *writeAPIBlocking + type AuthorizationsAPI interface + CreateAuthorization func(ctx context.Context, authorization *domain.Authorization) (*domain.Authorization, error) + CreateAuthorizationWithOrgID func(ctx context.Context, orgID string, permissions []domain.Permission) (*domain.Authorization, error) + DeleteAuthorization func(ctx context.Context, authorization *domain.Authorization) error + DeleteAuthorizationWithID func(ctx context.Context, authID string) error + FindAuthorizationsByOrgID func(ctx context.Context, orgID string) (*[]domain.Authorization, error) + FindAuthorizationsByOrgName func(ctx context.Context, orgName string) (*[]domain.Authorization, error) + FindAuthorizationsByUserID func(ctx context.Context, userID string) (*[]domain.Authorization, error) + FindAuthorizationsByUserName func(ctx context.Context, userName string) (*[]domain.Authorization, error) + GetAuthorizations func(ctx context.Context) (*[]domain.Authorization, error) + UpdateAuthorizationStatus func(ctx context.Context, authorization *domain.Authorization, ...) (*domain.Authorization, error) + UpdateAuthorizationStatusWithID func(ctx context.Context, authID string, ...) (*domain.Authorization, error) + func NewAuthorizationsAPI(apiClient *domain.ClientWithResponses) AuthorizationsAPI + type BucketsAPI interface + AddMember func(ctx context.Context, bucket *domain.Bucket, user *domain.User) (*domain.ResourceMember, error) + AddMemberWithID func(ctx context.Context, bucketID, memberID string) (*domain.ResourceMember, error) + AddOwner func(ctx context.Context, bucket *domain.Bucket, user *domain.User) (*domain.ResourceOwner, error) + AddOwnerWithID func(ctx context.Context, bucketID, memberID string) (*domain.ResourceOwner, error) + CreateBucket func(ctx context.Context, bucket *domain.Bucket) (*domain.Bucket, error) + CreateBucketWithName func(ctx context.Context, org *domain.Organization, bucketName string, ...) (*domain.Bucket, error) + CreateBucketWithNameWithID func(ctx context.Context, orgID, bucketName string, rules ...domain.RetentionRule) (*domain.Bucket, error) + DeleteBucket func(ctx context.Context, bucket *domain.Bucket) error + DeleteBucketWithID func(ctx context.Context, bucketID string) error + FindBucketByID func(ctx context.Context, bucketID string) (*domain.Bucket, error) + FindBucketByName func(ctx context.Context, bucketName string) (*domain.Bucket, error) + FindBucketsByOrgID func(ctx context.Context, orgID string, pagingOptions ...PagingOption) (*[]domain.Bucket, error) + FindBucketsByOrgName func(ctx context.Context, orgName string, pagingOptions ...PagingOption) (*[]domain.Bucket, error) + GetBuckets func(ctx context.Context, pagingOptions ...PagingOption) (*[]domain.Bucket, error) + GetMembers func(ctx context.Context, bucket *domain.Bucket) (*[]domain.ResourceMember, error) + GetMembersWithID func(ctx context.Context, bucketID string) (*[]domain.ResourceMember, error) + GetOwners func(ctx context.Context, bucket *domain.Bucket) (*[]domain.ResourceOwner, error) + GetOwnersWithID func(ctx context.Context, bucketID string) (*[]domain.ResourceOwner, error) + RemoveMember func(ctx context.Context, bucket *domain.Bucket, user *domain.User) error + RemoveMemberWithID func(ctx context.Context, bucketID, memberID string) error + RemoveOwner func(ctx context.Context, bucket *domain.Bucket, user *domain.User) error + RemoveOwnerWithID func(ctx context.Context, bucketID, memberID string) error + UpdateBucket func(ctx context.Context, bucket *domain.Bucket) (*domain.Bucket, error) + func NewBucketsAPI(apiClient *domain.ClientWithResponses) BucketsAPI + type DeleteAPI interface + Delete func(ctx context.Context, org *domain.Organization, bucket *domain.Bucket, ...) error + DeleteWithID func(ctx context.Context, orgID, bucketID string, start, stop time.Time, ...) error + DeleteWithName func(ctx context.Context, orgName, bucketName string, start, stop time.Time, ...) error + func NewDeleteAPI(apiClient *domain.ClientWithResponses) DeleteAPI + type LabelsAPI interface + CreateLabel func(ctx context.Context, label *domain.LabelCreateRequest) (*domain.Label, error) + CreateLabelWithName func(ctx context.Context, org *domain.Organization, labelName string, ...) (*domain.Label, error) + CreateLabelWithNameWithID func(ctx context.Context, orgID, labelName string, properties map[string]string) (*domain.Label, error) + DeleteLabel func(ctx context.Context, label *domain.Label) error + DeleteLabelWithID func(ctx context.Context, labelID string) error + FindLabelByID func(ctx context.Context, labelID string) (*domain.Label, error) + FindLabelByName func(ctx context.Context, orgID, labelName string) (*domain.Label, error) + FindLabelsByOrg func(ctx context.Context, org *domain.Organization) (*[]domain.Label, error) + FindLabelsByOrgID func(ctx context.Context, orgID string) (*[]domain.Label, error) + GetLabels func(ctx context.Context) (*[]domain.Label, error) + UpdateLabel func(ctx context.Context, label *domain.Label) (*domain.Label, error) + func NewLabelsAPI(apiClient *domain.ClientWithResponses) LabelsAPI + type OrganizationsAPI interface + AddMember func(ctx context.Context, org *domain.Organization, user *domain.User) (*domain.ResourceMember, error) + AddMemberWithID func(ctx context.Context, orgID, memberID string) (*domain.ResourceMember, error) + AddOwner func(ctx context.Context, org *domain.Organization, user *domain.User) (*domain.ResourceOwner, error) + AddOwnerWithID func(ctx context.Context, orgID, memberID string) (*domain.ResourceOwner, error) + CreateOrganization func(ctx context.Context, org *domain.Organization) (*domain.Organization, error) + CreateOrganizationWithName func(ctx context.Context, orgName string) (*domain.Organization, error) + DeleteOrganization func(ctx context.Context, org *domain.Organization) error + DeleteOrganizationWithID func(ctx context.Context, orgID string) error + FindOrganizationByID func(ctx context.Context, orgID string) (*domain.Organization, error) + FindOrganizationByName func(ctx context.Context, orgName string) (*domain.Organization, error) + FindOrganizationsByUserID func(ctx context.Context, userID string) (*[]domain.Organization, error) + GetMembers func(ctx context.Context, org *domain.Organization) (*[]domain.ResourceMember, error) + GetMembersWithID func(ctx context.Context, orgID string) (*[]domain.ResourceMember, error) + GetOrganizations func(ctx context.Context) (*[]domain.Organization, error) + GetOwners func(ctx context.Context, org *domain.Organization) (*[]domain.ResourceOwner, error) + GetOwnersWithID func(ctx context.Context, orgID string) (*[]domain.ResourceOwner, error) + RemoveMember func(ctx context.Context, org *domain.Organization, user *domain.User) error + RemoveMemberWithID func(ctx context.Context, orgID, memberID string) error + RemoveOwner func(ctx context.Context, org *domain.Organization, user *domain.User) error + RemoveOwnerWithID func(ctx context.Context, orgID, memberID string) error + UpdateOrganization func(ctx context.Context, org *domain.Organization) (*domain.Organization, error) + func NewOrganizationsAPI(apiClient *domain.ClientWithResponses) OrganizationsAPI + type Paging struct + type PagingOption func(p *Paging) + func PagingWithDescending(descending bool) PagingOption + func PagingWithLimit(limit int) PagingOption + func PagingWithOffset(offset int) PagingOption + func PagingWithSortBy(sortBy string) PagingOption + type QueryAPI interface + Query func(ctx context.Context, query string) (*QueryTableResult, error) + QueryRaw func(ctx context.Context, query string, dialect *domain.Dialect) (string, error) + func NewQueryAPI(org string, service http2.Service) QueryAPI + type QueryTableResult struct + func (q *QueryTableResult) Err() error + func (q *QueryTableResult) Next() bool + func (q *QueryTableResult) Record() *query.FluxRecord + func (q *QueryTableResult) TableChanged() bool + func (q *QueryTableResult) TableMetadata() *query.FluxTableMetadata + func (q *QueryTableResult) TablePosition() int + type UsersAPI interface + CreateUser func(ctx context.Context, user *domain.User) (*domain.User, error) + CreateUserWithName func(ctx context.Context, userName string) (*domain.User, error) + DeleteUser func(ctx context.Context, user *domain.User) error + DeleteUserWithID func(ctx context.Context, userID string) error + FindUserByID func(ctx context.Context, userID string) (*domain.User, error) + FindUserByName func(ctx context.Context, userName string) (*domain.User, error) + GetUsers func(ctx context.Context) (*[]domain.User, error) + Me func(ctx context.Context) (*domain.User, error) + MeUpdatePassword func(ctx context.Context, password string) error + UpdateUser func(ctx context.Context, user *domain.User) (*domain.User, error) + UpdateUserPassword func(ctx context.Context, user *domain.User, password string) error + UpdateUserPasswordWithID func(ctx context.Context, userID string, password string) error + func NewUsersAPI(apiClient *domain.ClientWithResponses) UsersAPI + type WriteAPI interface + Errors func() <-chan error + Flush func() + WritePoint func(point *write.Point) + WriteRecord func(line string) + type WriteAPIBlocking interface + WritePoint func(ctx context.Context, point ...*write.Point) error + WriteRecord func(ctx context.Context, line ...string) error + type WriteAPIImpl struct + func NewWriteAPI(org string, bucket string, service http2.Service, writeOptions *write.Options) *WriteAPIImpl + func (w *WriteAPIImpl) Close() + func (w *WriteAPIImpl) Errors() <-chan error + func (w *WriteAPIImpl) Flush() + func (w *WriteAPIImpl) WritePoint(point *write.Point) + func (w *WriteAPIImpl) WriteRecord(line string)