api

package

Go to main page

Versions in this module

v1

v1.4.0

Jul 17, 2020

Changes in this version

+ func NewWriteAPI(org string, bucket string, service http.Service, writeOptions *write.Options) *writeAPI

+ func NewWriteAPIBlocking(org string, bucket string, service http.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 AuthorizationsApi

+ 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

+ AddLabel func(ctx context.Context, org *domain.Organization, label *domain.Label) (*domain.Label, error)

+ AddLabelWithID func(ctx context.Context, orgID, labelID string) (*domain.Label, error)

+ 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)

+ GetLabels func(ctx context.Context, org *domain.Organization) (*[]domain.Label, error)

+ GetLabelsWithID func(ctx context.Context, orgID string) (*[]domain.Label, 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)

+ RemoveLabel func(ctx context.Context, org *domain.Organization, label *domain.Label) error

+ RemoveLabelWithID func(ctx context.Context, orgID, labelID string) 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 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 ihttp.Service) QueryAPI

+ 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

+ Close func()

+ 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

v1.3.0

Jun 19, 2020

Changes in this version

+ 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

+ AddLabel func(ctx context.Context, org *domain.Organization, label *domain.Label) (*domain.Label, error)

+ AddLabelWithId func(ctx context.Context, orgId, labelId string) (*domain.Label, error)

+ GetLabels func(ctx context.Context, org *domain.Organization) (*[]domain.Label, error)

+ GetLabelsWithId func(ctx context.Context, orgId string) (*[]domain.Label, error)

+ RemoveLabel func(ctx context.Context, org *domain.Organization, label *domain.Label) error

+ RemoveLabelWithId func(ctx context.Context, orgId, labelId string) error

v1.2.0

May 15, 2020

Changes in this version

+ func DefaultDialect() *domain.Dialect

+ func NewWriteApiBlockingImpl(org string, bucket string, service http.Service, writeOptions *write.Options) *writeApiBlockingImpl

+ func NewWriteApiImpl(org string, bucket string, service http.Service, writeOptions *write.Options) *writeApiImpl

+ 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)

+ GetLogs func(ctx context.Context, bucket *domain.Bucket, pagingOptions ...PagingOption) (*[]domain.OperationLog, error)

+ GetLogsWithId func(ctx context.Context, bucketId string, pagingOptions ...PagingOption) (*[]domain.OperationLog, 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 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 ihttp.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 WriteApi interface

+ Close func()

+ 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

v1.1.0

Apr 24, 2020

Changes in this version

+ 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, 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, authId string, ...) (*domain.Authorization, error)

+ func NewAuthorizationApi(service ihttp.Service) AuthorizationsApi

+ 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, orgId 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(service ihttp.Service) OrganizationsApi

+ 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(service ihttp.Service) UsersApi

Other modules containing this package

github.com/influxdata/influxdb-client-go/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL