bq

Documentation

Index

• Constants
• func ToInterfaceSlice(slice interface{}) ([]interface{}, error)
• type Client
  • func NewClientWrapper(gcpProjectID string) Client
  • func NewInMemoryClient() Client
• type ClientWrapper
  • func (c *ClientWrapper) GetAnnouncementCount(from int64) (int64, error)
  • func (c *ClientWrapper) Insert(tableId string, src interface{}) error
• type InMemoryClient
  • func (c *InMemoryClient) GetAnnouncementCount(from int64) (int64, error)
  • func (c *InMemoryClient) Insert(tableId string, src interface{}) error

Constants

const (
	EnvKeyBQToken = "BIGQUERY_KEY"

	TableAnnouncement = "announcement"
)

Functions

func ToInterfaceSlice

func ToInterfaceSlice(slice interface{}) ([]interface{}, error)

Types

type Client

type Client interface {
	Insert(tableId string, src interface{}) error
	GetAnnouncementCount(from int64) (int64, error)
}

func NewClientWrapper

func NewClientWrapper(gcpProjectID string) Client

func NewInMemoryClient

func NewInMemoryClient() Client

type ClientWrapper

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

func (*ClientWrapper) GetAnnouncementCount

func (c *ClientWrapper) GetAnnouncementCount(from int64) (int64, error)

func (*ClientWrapper) Insert

func (c *ClientWrapper) Insert(tableId string, src interface{}) error

type InMemoryClient

type InMemoryClient struct{}

func (*InMemoryClient) GetAnnouncementCount

func (c *InMemoryClient) GetAnnouncementCount(from int64) (int64, error)

func (*InMemoryClient) Insert

func (c *InMemoryClient) Insert(tableId string, src interface{}) error