server

Documentation

Index

• Constants
• Variables
• func NewBigQueryClient(ctx context.Context, cfg *opt.Config) (*bigquery.Client, error)
• func NewBigQueryServer(cfg *opt.Config, keyManager model.KeyManager, ...) plspb.LogServer
• func NewBigQueryTable(ctx context.Context, cfg *opt.Config, client *bigquery.Client) (*bigquery.Table, error)
• func NewInMemoryServer(cfg *opt.Config, keyManager model.KeyManager, ...) plspb.LogServer
• type BigQueryServer
  • func (s *BigQueryServer) Create(ctx context.Context, in *plspb.LogCreateRequest) (*plspb.LogCreateResponse, error)
  • func (s *BigQueryServer) Delete(ctx context.Context, in *plspb.LogDeleteRequest) (*plspb.LogDeleteResponse, error)
  • func (s *BigQueryServer) List(in *plspb.LogListRequest, stream plspb.Log_ListServer) error
  • func (s *BigQueryServer) MessageAppend(ctx context.Context, in *plspb.LogMessageAppendRequest) (*plspb.LogMessageAppendResponse, error)
  • func (s *BigQueryServer) MessageList(in *plspb.LogMessageListRequest, stream plspb.Log_MessageListServer) error
• type BigQueryTableQueryBuilder
  • func NewBigQueryTableQueryBuilder() *BigQueryTableQueryBuilder
  • func (qb *BigQueryTableQueryBuilder) After(after *time.Time)
  • func (qb *BigQueryTableQueryBuilder) Before(before *time.Time)
  • func (qb *BigQueryTableQueryBuilder) Build() (*bigquery.Query, error)
  • func (qb *BigQueryTableQueryBuilder) WithClient(client *bigquery.Client)
  • func (qb *BigQueryTableQueryBuilder) WithEncryptionKey(encryptionKey string)
  • func (qb *BigQueryTableQueryBuilder) WithEndAt(endAt *time.Time)
  • func (qb *BigQueryTableQueryBuilder) WithLog(logID string)
  • func (qb *BigQueryTableQueryBuilder) WithStartAt(startAt *time.Time)
  • func (qb *BigQueryTableQueryBuilder) WithTable(table *bigquery.Table)
• type InMemoryServer
  • func (s *InMemoryServer) Create(ctx context.Context, in *plspb.LogCreateRequest) (*plspb.LogCreateResponse, error)
  • func (s *InMemoryServer) Delete(ctx context.Context, in *plspb.LogDeleteRequest) (*plspb.LogDeleteResponse, error)
  • func (s *InMemoryServer) List(in *plspb.LogListRequest, stream plspb.Log_ListServer) error
  • func (s *InMemoryServer) MessageAppend(ctx context.Context, in *plspb.LogMessageAppendRequest) (*plspb.LogMessageAppendResponse, error)
  • func (s *InMemoryServer) MessageList(in *plspb.LogMessageListRequest, stream plspb.Log_MessageListServer) error
• type LogMessage
  • func (lm *LogMessage) Save() (map[string]bigquery.Value, string, error)
• type QueryColumn

Constants

const (
	BigQueryTimestampFormat = "2006-01-02 15:04:05.999999 UTC"
)

Variables

var (
	ErrNotFound = errors.New("error: not found")
	ErrInvalid  = errors.New("error: invalid")
)

var BigQueryServerSet = wire.NewSet(
	NewBigQueryServer,
	NewBigQueryClient,
	NewBigQueryTable,
)

var InMemoryServerSet = wire.NewSet(
	NewInMemoryServer,
)

Functions

func NewBigQueryClient

func NewBigQueryClient(ctx context.Context, cfg *opt.Config) (*bigquery.Client, error)

func NewBigQueryServer

func NewBigQueryServer(cfg *opt.Config,
	keyManager model.KeyManager, logMetadataManager model.LogMetadataManager,
	bigQueryClient *bigquery.Client, bigQueryTable *bigquery.Table,
	meter *metric.Meter) plspb.LogServer

func NewBigQueryTable

func NewBigQueryTable(ctx context.Context, cfg *opt.Config, client *bigquery.Client) (*bigquery.Table, error)

func NewInMemoryServer

func NewInMemoryServer(cfg *opt.Config,
	keyManager model.KeyManager, logMetadataManager model.LogMetadataManager) plspb.LogServer

Types

type BigQueryServer

type BigQueryServer struct {
	plspb.UnimplementedLogServer
	// contains filtered or unexported fields
}

func (*BigQueryServer) Create

func (s *BigQueryServer) Create(ctx context.Context, in *plspb.LogCreateRequest) (*plspb.LogCreateResponse, error)

func (*BigQueryServer) Delete

func (s *BigQueryServer) Delete(ctx context.Context, in *plspb.LogDeleteRequest) (*plspb.LogDeleteResponse, error)

func (*BigQueryServer) List

func (s *BigQueryServer) List(in *plspb.LogListRequest, stream plspb.Log_ListServer) error

func (*BigQueryServer) MessageAppend

func (s *BigQueryServer) MessageAppend(ctx context.Context, in *plspb.LogMessageAppendRequest) (*plspb.LogMessageAppendResponse, error)

func (*BigQueryServer) MessageList

func (s *BigQueryServer) MessageList(in *plspb.LogMessageListRequest, stream plspb.Log_MessageListServer) error

type BigQueryTableQueryBuilder

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

func NewBigQueryTableQueryBuilder

func NewBigQueryTableQueryBuilder() *BigQueryTableQueryBuilder

func (*BigQueryTableQueryBuilder) After

func (qb *BigQueryTableQueryBuilder) After(after *time.Time)

func (*BigQueryTableQueryBuilder) Before

func (qb *BigQueryTableQueryBuilder) Before(before *time.Time)

func (*BigQueryTableQueryBuilder) Build

func (qb *BigQueryTableQueryBuilder) Build() (*bigquery.Query, error)

func (*BigQueryTableQueryBuilder) WithClient

func (qb *BigQueryTableQueryBuilder) WithClient(client *bigquery.Client)

func (*BigQueryTableQueryBuilder) WithEncryptionKey

func (qb *BigQueryTableQueryBuilder) WithEncryptionKey(encryptionKey string)

func (*BigQueryTableQueryBuilder) WithEndAt

func (qb *BigQueryTableQueryBuilder) WithEndAt(endAt *time.Time)

func (*BigQueryTableQueryBuilder) WithLog

func (qb *BigQueryTableQueryBuilder) WithLog(logID string)

func (*BigQueryTableQueryBuilder) WithStartAt

func (qb *BigQueryTableQueryBuilder) WithStartAt(startAt *time.Time)

func (*BigQueryTableQueryBuilder) WithTable

func (qb *BigQueryTableQueryBuilder) WithTable(table *bigquery.Table)

type InMemoryServer

type InMemoryServer struct {
	plspb.UnimplementedLogServer
	// contains filtered or unexported fields
}

func (*InMemoryServer) Create

func (s *InMemoryServer) Create(ctx context.Context, in *plspb.LogCreateRequest) (*plspb.LogCreateResponse, error)

func (*InMemoryServer) Delete

func (s *InMemoryServer) Delete(ctx context.Context, in *plspb.LogDeleteRequest) (*plspb.LogDeleteResponse, error)

func (*InMemoryServer) List

func (s *InMemoryServer) List(in *plspb.LogListRequest, stream plspb.Log_ListServer) error

func (*InMemoryServer) MessageAppend

func (s *InMemoryServer) MessageAppend(ctx context.Context, in *plspb.LogMessageAppendRequest) (*plspb.LogMessageAppendResponse, error)

func (*InMemoryServer) MessageList

func (s *InMemoryServer) MessageList(in *plspb.LogMessageListRequest, stream plspb.Log_MessageListServer) error

type LogMessage

type LogMessage struct {
	LogID            string
	LogMessageID     string
	Timestamp        time.Time
	EncryptedPayload []byte
}

func (*LogMessage) Save

func (lm *LogMessage) Save() (map[string]bigquery.Value, string, error)

type QueryColumn

type QueryColumn int

const (
	QueryColumnPayload QueryColumn = iota
	QueryColumnTimestamp
	QueryColumnLogMessageID
)