commander

Documentation

Index

• type Commander
  • func New(config configuration.Configuration) (*Commander, error)
  • func (c *Commander) APIVersion(ctx *fiber.Ctx) error
  • func (c *Commander) CreateJob(ctx *fiber.Ctx) error
  • func (c *Commander) CreateTable(ctx *fiber.Ctx) error
  • func (c *Commander) CreateTenant(ctx *fiber.Ctx) error
  • func (c *Commander) DeleteJob(ctx *fiber.Ctx) error
  • func (c *Commander) DeleteTable(ctx *fiber.Ctx) error
  • func (c *Commander) DeleteTenant(ctx *fiber.Ctx) error
  • func (c *Commander) GetHost() string
  • func (c *Commander) GetID() string
  • func (c *Commander) GetJob(ctx *fiber.Ctx) error
  • func (c *Commander) GetJobs(ctx *fiber.Ctx) error
  • func (c *Commander) GetMetadata() map[string]string
  • func (c *Commander) GetName() string
  • func (c *Commander) GetPort() string
  • func (c *Commander) GetTable(ctx *fiber.Ctx) error
  • func (c *Commander) GetTables(ctx *fiber.Ctx) error
  • func (c *Commander) GetTenant(ctx *fiber.Ctx) error
  • func (c *Commander) GetTenants(ctx *fiber.Ctx) error
  • func (c *Commander) PatchJob(ctx *fiber.Ctx) error
  • func (c *Commander) PatchTable(ctx *fiber.Ctx) error
  • func (c *Commander) PatchTenant(ctx *fiber.Ctx) error
  • func (c *Commander) ShutdownServer() error
  • func (c *Commander) StartServer(address string) error
  • func (c *Commander) UpdateJob(ctx *fiber.Ctx) error
  • func (c *Commander) UpdateTable(ctx *fiber.Ctx) error
  • func (c *Commander) UpdateTenant(ctx *fiber.Ctx) error
• type CreateIngestionJobRequest
• type CreateTableRequest

Types

type Commander

type Commander struct {
	Name     string
	ID       uuid.UUID
	Hostname string
	// contains filtered or unexported fields
}

func New

func New(config configuration.Configuration) (*Commander, error)

func (*Commander) APIVersion

func (c *Commander) APIVersion(ctx *fiber.Ctx) error

func (*Commander) CreateJob

func (c *Commander) CreateJob(ctx *fiber.Ctx) error

func (*Commander) CreateTable

func (c *Commander) CreateTable(ctx *fiber.Ctx) error

func (*Commander) CreateTenant

func (c *Commander) CreateTenant(ctx *fiber.Ctx) error

func (*Commander) DeleteJob

func (c *Commander) DeleteJob(ctx *fiber.Ctx) error

func (*Commander) DeleteTable

func (c *Commander) DeleteTable(ctx *fiber.Ctx) error

func (*Commander) DeleteTenant

func (c *Commander) DeleteTenant(ctx *fiber.Ctx) error

func (*Commander) GetHost

func (c *Commander) GetHost() string

func (*Commander) GetID

func (c *Commander) GetID() string

func (*Commander) GetJob

func (c *Commander) GetJob(ctx *fiber.Ctx) error

func (*Commander) GetJobs

func (c *Commander) GetJobs(ctx *fiber.Ctx) error

func (*Commander) GetMetadata

func (c *Commander) GetMetadata() map[string]string

func (*Commander) GetName

func (c *Commander) GetName() string

func (*Commander) GetPort

func (c *Commander) GetPort() string

func (*Commander) GetTable

func (c *Commander) GetTable(ctx *fiber.Ctx) error

func (*Commander) GetTables

func (c *Commander) GetTables(ctx *fiber.Ctx) error

func (*Commander) GetTenant

func (c *Commander) GetTenant(ctx *fiber.Ctx) error

func (*Commander) GetTenants

func (c *Commander) GetTenants(ctx *fiber.Ctx) error

Tenant routes

func (*Commander) PatchJob

func (c *Commander) PatchJob(ctx *fiber.Ctx) error

func (*Commander) PatchTable

func (c *Commander) PatchTable(ctx *fiber.Ctx) error

func (*Commander) PatchTenant

func (c *Commander) PatchTenant(ctx *fiber.Ctx) error

func (*Commander) ShutdownServer

func (c *Commander) ShutdownServer() error

func (*Commander) StartServer

func (c *Commander) StartServer(address string) error

func (*Commander) UpdateJob

func (c *Commander) UpdateJob(ctx *fiber.Ctx) error

func (*Commander) UpdateTable

func (c *Commander) UpdateTable(ctx *fiber.Ctx) error

func (*Commander) UpdateTenant

func (c *Commander) UpdateTenant(ctx *fiber.Ctx) error

type CreateIngestionJobRequest

type CreateIngestionJobRequest struct {
	Job cingestion.IngestionJobConfiguration `json:"job"`
}

Ingestion Job routes

type CreateTableRequest

type CreateTableRequest struct {
	Table entities.Table `json:"table"`
}

Table routes