Versions in this module Expand all Collapse all v2 v2.5.4 Nov 24, 2021 Changes in this version + func DefaultDialect() *domain.Dialect + 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, pagingOptions ...PagingOption) (*[]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, pagingOptions ...PagingOption) (*[]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 PagingWithAfter(after string) PagingOption + 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) Close() error + 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 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 + 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, oldPassword, newPassword string) error + SignIn func(ctx context.Context, username, password string) error + SignOut func(ctx context.Context) 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, httpService http.Service, ...) UsersAPI + type WriteAPI interface + Errors func() <-chan error + Flush func() + SetWriteFailedCallback func(cb WriteFailedCallback) + 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 + func NewWriteAPIBlocking(org string, bucket string, service http2.Service, writeOptions *write.Options) WriteAPIBlocking + 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) SetWriteFailedCallback(cb WriteFailedCallback) + func (w *WriteAPIImpl) WritePoint(point *write.Point) + func (w *WriteAPIImpl) WriteRecord(line string) + type WriteFailedCallback func(batch string, error http2.Error, retryAttempts uint) bool