Documentation ¶
Index ¶
- Constants
- type ApiServer
- func (as *ApiServer) CheckCompatibility(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) CheckRegistered(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) GetGlobalConfig(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
- func (as *ApiServer) GetSchema(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) GetSubjectConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) GetSubjects(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) GetVersion(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) GetVersionList(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) NewSchema(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) Start() error
- func (as *ApiServer) UpdateGlobalConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- func (as *ApiServer) UpdateSubjectConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
- type CompatibilityMessage
- type ErrorMessage
- type Schema
- type SchemaMessage
- type UserRequest
- type VersionMessage
- type Watcher
Constants ¶
View Source
const ( ErrSchemaNotFound = "Schema not found" ErrInBackendStore = "Error in the backend datastore" ErrAuthStore = "Error in authorization backend" ErrEncoding = "Error encoding response" ErrDecoding = "Error decoding request" ErrSubjectNotFound = "Subject not found" ErrInvalidSchema = "Invalid Avro schema" ErrIncompatibleSchema = "Incompatible Avro schema" ErrInvalidCompatibility = "Invalid compatibility level" ErrUserExists = "User already exists" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApiServer ¶
type ApiServer struct {
// contains filtered or unexported fields
}
func NewApiServer ¶
func (*ApiServer) CheckCompatibility ¶
func (as *ApiServer) CheckCompatibility(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) CheckRegistered ¶
func (as *ApiServer) CheckRegistered(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) GetGlobalConfig ¶
func (as *ApiServer) GetGlobalConfig(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
func (*ApiServer) GetSchema ¶
func (as *ApiServer) GetSchema(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) GetSubjectConfig ¶
func (as *ApiServer) GetSubjectConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) GetSubjects ¶
func (as *ApiServer) GetSubjects(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) GetVersion ¶
func (as *ApiServer) GetVersion(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) GetVersionList ¶
func (as *ApiServer) GetVersionList(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) NewSchema ¶
func (as *ApiServer) NewSchema(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) UpdateGlobalConfig ¶
func (as *ApiServer) UpdateGlobalConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
func (*ApiServer) UpdateSubjectConfig ¶
func (as *ApiServer) UpdateSubjectConfig(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
type CompatibilityMessage ¶
type CompatibilityMessage struct {
IsCompatible bool `json:"is_compatible"`
}
type ErrorMessage ¶
type SchemaMessage ¶
type SchemaMessage struct {
Schema string `json:"schema"`
}
type UserRequest ¶
type VersionMessage ¶
Click to show internal directories.
Click to hide internal directories.