api

package

Go to main page

Versions in this module

v2

v2.13.0

Dec 5, 2023

Changes in this version

+ func DataToPoint(x interface{}) (*write.Point, error)

v2.12.4

Nov 3, 2023

v2.12.3

Mar 29, 2023

v2.12.2

Jan 26, 2023

v2.12.1

Dec 1, 2022

v2.12.0

Oct 27, 2022

v2.11.0

Sep 29, 2022

v2.10.0

Aug 25, 2022

Changes in this version

type WriteAPIBlocking

+ func NewWriteAPIBlockingWithBatching(org string, bucket string, service http2.Service, writeOptions *write.Options) WriteAPIBlocking

+ EnableBatching func()

+ Flush func(ctx context.Context) error

v2.9.2

Jul 29, 2022

v2.9.1

Jun 24, 2022

v2.9.0

May 20, 2022

Changes in this version

type TasksAPI

+ CreateTaskByFlux func(ctx context.Context, flux, orgID string) (*domain.Task, error)

v2.8.2

Apr 19, 2022

v2.8.1

Mar 21, 2022

v2.8.0

Feb 18, 2022

Changes in this version

type QueryAPI

+ QueryRawWithParams func(ctx context.Context, query string, dialect *domain.Dialect, params interface{}) (string, error)

+ QueryWithParams func(ctx context.Context, query string, params interface{}) (*QueryTableResult, error)

type QueryTableResult

+ func NewQueryTableResult(rawResponse io.ReadCloser) *QueryTableResult

v2.7.0

Jan 20, 2022

v2.6.0

Nov 26, 2021

v2.5.1

Sep 17, 2021

v2.5.0

Aug 20, 2021

Changes in this version

type WriteAPI

+ SetWriteFailedCallback func(cb WriteFailedCallback)

type WriteAPIImpl

+ func (w *WriteAPIImpl) SetWriteFailedCallback(cb WriteFailedCallback)

+ type WriteFailedCallback func(batch string, error http2.Error, retryAttempts uint) bool

v2.4.0

Jun 4, 2021

Changes in this version

type QueryTableResult

+ func (q *QueryTableResult) Close() error

v2.3.0

Apr 30, 2021

v2.2.3

Apr 1, 2021

v2.2.2

Jan 29, 2021

v2.2.1

Dec 24, 2020

v2.2.0

Oct 30, 2020

Changes in this version

+ type RunFilter struct

+ After string

+ AfterTime time.Time

+ BeforeTime time.Time

+ Limit int

+ type TaskFilter struct

+ After string

+ Limit int

+ Name string

+ OrgID string

+ OrgName string

+ Status domain.TaskStatusType

+ User string

+ type TasksAPI interface

+ AddLabel func(ctx context.Context, task *domain.Task, label *domain.Label) (*domain.Label, error)

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

+ AddMember func(ctx context.Context, task *domain.Task, user *domain.User) (*domain.ResourceMember, error)

+ AddMemberWithID func(ctx context.Context, taskID, memberID string) (*domain.ResourceMember, error)

+ AddOwner func(ctx context.Context, task *domain.Task, user *domain.User) (*domain.ResourceOwner, error)

+ AddOwnerWithID func(ctx context.Context, taskID, memberID string) (*domain.ResourceOwner, error)

+ CancelRun func(ctx context.Context, run *domain.Run) error

+ CancelRunWithID func(ctx context.Context, taskID, runID string) error

+ CreateTask func(ctx context.Context, task *domain.Task) (*domain.Task, error)

+ CreateTaskWithCron func(ctx context.Context, name, flux, cron, orgID string) (*domain.Task, error)

+ CreateTaskWithEvery func(ctx context.Context, name, flux, every, orgID string) (*domain.Task, error)

+ DeleteTask func(ctx context.Context, task *domain.Task) error

+ DeleteTaskWithID func(ctx context.Context, taskID string) error

+ FindLabels func(ctx context.Context, task *domain.Task) ([]domain.Label, error)

+ FindLabelsWithID func(ctx context.Context, taskID string) ([]domain.Label, error)

+ FindLogs func(ctx context.Context, task *domain.Task) ([]domain.LogEvent, error)

+ FindLogsWithID func(ctx context.Context, taskID string) ([]domain.LogEvent, error)

+ FindMembers func(ctx context.Context, task *domain.Task) ([]domain.ResourceMember, error)

+ FindMembersWithID func(ctx context.Context, taskID string) ([]domain.ResourceMember, error)

+ FindOwners func(ctx context.Context, task *domain.Task) ([]domain.ResourceOwner, error)

+ FindOwnersWithID func(ctx context.Context, taskID string) ([]domain.ResourceOwner, error)

+ FindRunLogs func(ctx context.Context, run *domain.Run) ([]domain.LogEvent, error)

+ FindRunLogsWithID func(ctx context.Context, taskID, runID string) ([]domain.LogEvent, error)

+ FindRuns func(ctx context.Context, task *domain.Task, filter *RunFilter) ([]domain.Run, error)

+ FindRunsWithID func(ctx context.Context, taskID string, filter *RunFilter) ([]domain.Run, error)

+ FindTasks func(ctx context.Context, filter *TaskFilter) ([]domain.Task, error)

+ GetRun func(ctx context.Context, run *domain.Run) (*domain.Run, error)

+ GetRunByID func(ctx context.Context, taskID, runID string) (*domain.Run, error)

+ GetTask func(ctx context.Context, task *domain.Task) (*domain.Task, error)

+ GetTaskByID func(ctx context.Context, taskID string) (*domain.Task, error)

+ RemoveLabel func(ctx context.Context, task *domain.Task, label *domain.Label) error

+ RemoveLabelWithID func(ctx context.Context, taskID, labelID string) error

+ RemoveMember func(ctx context.Context, task *domain.Task, user *domain.User) error

+ RemoveMemberWithID func(ctx context.Context, taskID, memberID string) error

+ RemoveOwner func(ctx context.Context, task *domain.Task, user *domain.User) error

+ RemoveOwnerWithID func(ctx context.Context, taskID, memberID string) error

+ RetryRun func(ctx context.Context, run *domain.Run) (*domain.Run, error)

+ RetryRunWithID func(ctx context.Context, taskID, runID string) (*domain.Run, error)

+ RunManually func(ctx context.Context, task *domain.Task) (*domain.Run, error)

+ RunManuallyWithID func(ctx context.Context, taskID string) (*domain.Run, error)

+ UpdateTask func(ctx context.Context, task *domain.Task) (*domain.Task, error)

+ func NewTasksAPI(apiClient *domain.ClientWithResponses) TasksAPI

v2.1.0

Oct 2, 2020

Changes in this version

type PagingOption

+ func PagingWithAfter(after string) PagingOption

type UsersAPI

+ SignIn func(ctx context.Context, username, password string) error

+ SignOut func(ctx context.Context) error

v2.0.1

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)

Other modules containing this package

github.com/influxdata/influxdb-client-go

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