bigquery

package

v0.0.0-...-7fad99f Latest Latest Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ntail-io/streams

Documentation ¶

Index ¶

func ParseUUID(time uuid.Time, seq uint16, nodeId []byte) uuid.UUID
type ReaderService
- func NewReaderService(client *storage.BigQueryReadClient, project string) *ReaderService
- func (s *ReaderService) NewSession(ctx context.Context, addr *domain.SegmentAddress, fromMsgId uuid.UUID) (*ReaderSession, error)
type ReaderSession
- func NewReader(ctx context.Context, client *storage.BigQueryReadClient, projectId string, ...) (*ReaderSession, error)
- func (r *ReaderSession) Poll(ctx context.Context, buf []byte) (out []byte, lastMsgId uuid.UUID, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ParseUUID ¶

func ParseUUID(time uuid.Time, seq uint16, nodeId []byte) uuid.UUID

Types ¶

type ReaderService ¶

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

func NewReaderService ¶

func NewReaderService(client *storage.BigQueryReadClient, project string) *ReaderService

func (*ReaderService) NewSession ¶

func (s *ReaderService) NewSession(ctx context.Context, addr *domain.SegmentAddress, fromMsgId uuid.UUID) (*ReaderSession, error)

type ReaderSession ¶

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

func NewReader ¶

func NewReader(ctx context.Context, client *storage.BigQueryReadClient, projectId string, fromMsgId uuid.UUID, table string, traceId string) (*ReaderSession, error)

func (*ReaderSession) Poll ¶

func (r *ReaderSession) Poll(ctx context.Context, buf []byte) (out []byte, lastMsgId uuid.UUID, err error)

Source Files ¶

View all Source files

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