writer

Documentation

Index

• type Manager
  • func NewManger(ctx context.Context, mwClient *mw.Client, proto *descriptorpb.DescriptorProto, ...) (*Manager, error)
  • func (x *Manager) Close() error
  • func (x *Manager) Renew(ctx context.Context) error
  • func (x *Manager) Writer(ctx context.Context) *writer

Types

type Manager

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

func NewManger

func NewManger(ctx context.Context, mwClient *mw.Client, proto *descriptorpb.DescriptorProto, projectID types.GoogleProjectID, datasetID types.BQDatasetID, tableID types.BQTableID) (*Manager, error)

func (*Manager) Close

func (x *Manager) Close() error

func (*Manager) Renew

func (x *Manager) Renew(ctx context.Context) error

func (*Manager) Writer

func (x *Manager) Writer(ctx context.Context) *writer