Versions in this module Expand all Collapse all v0 v0.1.3 Dec 2, 2024 Changes in this version + type BigQuery interface + CreateTable func(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, ...) error + GetMetadata func(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID) (*bigquery.TableMetadata, error) + NewStream func(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, ...) (BigQueryStream, error) + Query func(ctx context.Context, query string) (BigQueryIterator, error) + UpdateTable func(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, ...) error + type BigQueryIterator interface + Next func(dst interface{}) error + type BigQueryStream interface + Close func() error + Insert func(ctx context.Context, data []any) error + type CSObjectIterator interface + Next func() (*storage.ObjectAttrs, error) + type CloudStorage interface + Attrs func(ctx context.Context, obj model.CloudStorageObject) (*storage.ObjectAttrs, error) + List func(ctx context.Context, bucket types.CSBucket, query *storage.Query) CSObjectIterator + Open func(ctx context.Context, obj model.CloudStorageObject) (io.ReadCloser, error) + type Database interface + GetOrCreateState func(ctx context.Context, msgType types.MsgType, input *model.State) (*model.State, bool, error) + GetState func(ctx context.Context, msgType types.MsgType, id string) (*model.State, error) + UpdateState func(ctx context.Context, msgType types.MsgType, id string, state types.MsgState, ...) error + type PubSubSubscription interface + Acknowledge func(ctx context.Context, subName string, ackID string) error + Close func() error + ModifyAckDeadline func(ctx context.Context, subName string, ackID string, deadline time.Duration) error + Pull func(ctx context.Context, subName string) ([]*pubsubpb.ReceivedMessage, error) + type PubSubTopic interface + Publish func(ctx context.Context, data []byte) (types.PubSubMessageID, error) + type UseCase interface + Authorize func(ctx context.Context, input *model.AuthPolicyInput) error + Enqueue func(ctx context.Context, req *model.EnqueueRequest) (*model.EnqueueResponse, error) + GetOrCreateState func(ctx context.Context, msgType types.MsgType, id string) (*model.State, bool, error) + Load func(ctx context.Context, requests []*model.LoadRequest) error + ObjectToSources func(ctx context.Context, obj model.Object) ([]*model.Source, error) + UpdateState func(ctx context.Context, msgType types.MsgType, id string, state types.MsgState) error + WaitState func(ctx context.Context, msgType types.MsgType, id string, expiresAt time.Time) error
Go to main page