server

Documentation

Index

• func SchemaChange(svc string, cluster string, sdb string, table string, inputType string, ...) error
• func SchemaRegister(svc string, cluster string, sdb string, table string, inputType string, ...) error
• func Shutdown()
• func StartHTTPServer(port int)

Functions

func SchemaChange

func SchemaChange(svc string, cluster string, sdb string, table string, inputType string, output string, version int, formatType string, alter string, dst string) error

SchemaChange handles the POST request to alter schema

func SchemaRegister

func SchemaRegister(svc string, cluster string, sdb string, table string, inputType string, output string, version int, formatType string, dst string, createTopic bool) error

SchemaRegister handles the POST request to get Avro schema from table definition for given service,db,table

func Shutdown

func Shutdown()

Shutdown gracefully stops the server

func StartHTTPServer

func StartHTTPServer(port int)

StartHTTPServer starts listening and serving traffic on configured port and sets up http routes.