sheets

Documentation

Index

• Variables
• type BatchReader
  • func NewBatchReader(ctx context.Context, args BatchReaderArgs) (*BatchReader, error)
  • func (b *BatchReader) GetSheetRecords(ctx context.Context, offset int64) ([]sdk.Record, error)
• type BatchReaderArgs
• type Writer
  • func NewWriter(ctx context.Context, oauthCfg *oauth2.Config, token *oauth2.Token, ...) (*Writer, error)
  • func (w *Writer) Write(ctx context.Context, records []sdk.Record) (int, error)

Variables

var (
	ErrEmptyPayload = errors.New("empty paylaod")
)

Types

type BatchReader

type BatchReader struct {
	// contains filtered or unexported fields
}

func NewBatchReader

func NewBatchReader(ctx context.Context, args BatchReaderArgs) (*BatchReader, error)

func (*BatchReader) GetSheetRecords

func (b *BatchReader) GetSheetRecords(ctx context.Context, offset int64) ([]sdk.Record, error)

GetSheetRecords returns the list of records up to a maximum of 1000 rows(default limit) added after the row offset of last successfully read record

type BatchReaderArgs

type BatchReaderArgs struct {
	OAuthConfig          *oauth2.Config
	OAuthToken           *oauth2.Token
	SpreadsheetID        string
	SheetID              int64
	DateTimeRenderOption string
	ValueRenderOption    string
	PollingPeriod        time.Duration
}

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

func NewWriter

func NewWriter(
	ctx context.Context,
	oauthCfg *oauth2.Config,
	token *oauth2.Token,
	spreadsheetID, sheetName, valueInputOption string,
	retries uint64,
) (*Writer, error)

func (*Writer) Write

func (w *Writer) Write(ctx context.Context, records []sdk.Record) (int, error)

Write function writes the records to google sheet