partitions

Documentation

Index

• type Handler
  • func NewHandler(ctx context.Context, pman *Manager) (*Handler, error)
  • func (h *Handler) Invoke(ctx context.Context, payload []byte) ([]byte, error)
• type Manager
  • func NewManager(queryBucket, region, database, table string) (*Manager, error)
  • func (m *Manager) CreatePartition(ctx context.Context, year, month string) error

Types

type Handler

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

func NewHandler

func NewHandler(ctx context.Context, pman *Manager) (*Handler, error)

func (*Handler) Invoke

func (h *Handler) Invoke(ctx context.Context, payload []byte) ([]byte, error)

type Manager

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

func NewManager

func NewManager(queryBucket, region, database, table string) (*Manager, error)

func (*Manager) CreatePartition

func (m *Manager) CreatePartition(ctx context.Context, year, month string) error