Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CRDBReader ¶
type CRDBReader struct {
// contains filtered or unexported fields
}
func NewCRDBReader ¶
func NewCRDBReader() *CRDBReader
func (*CRDBReader) Get ¶
func (r *CRDBReader) Get(ctx context.Context) ([]*handler.ResultData, error)
CREATE TABLE webnesday (attended STRING PRIMARY KEY, count INT);
type PubsubWriter ¶
type PubsubWriter struct {
// contains filtered or unexported fields
}
func NewPubsubWriter ¶
func NewPubsubWriter() *PubsubWriter
type ReaderMock ¶
type ReaderMock struct{}
func (*ReaderMock) Get ¶
func (m *ReaderMock) Get(context.Context) ([]*handler.ResultData, error)
type WriterMock ¶
type WriterMock struct{}
Click to show internal directories.
Click to hide internal directories.