schema

Documentation

Index

• Variables
• type PubRequestType
• type PubResponseType
• type RegisterSubRequestType
• type RegisterSubResponseType
• type ReqResRequestType
• type ReqResResponsetType
• type UnregisterSubRequestType
• type UnregisterSubResponseType

Variables

var PubRequest string

PubRequest is the text file loaded schema for PublishRequests

var PubRequestCodec = avro.CreateSchema(PubRequest)

PubRequestCodec is the prepared avro codec for PubRequests

var PubResponse string

PubResponse is the text file loaded schema for PubResponses

var PubResponseCodec = avro.CreateSchema(PubResponse)

PubResponseCodec is the prepared avro codec for PubResponses

var RegisterSubRequest string

RegisterSubRequest is the text file loaded schema for RegisterSubRequests

var RegisterSubRequestCodec = avro.CreateSchema(RegisterSubRequest)

RegisterSubRequestCodec is the prepared avro codec for RegisterSubRequests

var RegisterSubResponse string

RegisterSubResponse is the text file loaded schema for RegisterSubResponses

var RegisterSubResponseCodec = avro.CreateSchema(RegisterSubResponse)

RegisterSubResponseCodec is the prepared avro codec for RegisterSubResponses

var ReqResRequest string

ReqResRequest is the text file loaded schema for Request Response Requests

var ReqResRequestCodec = avro.CreateSchema(ReqResRequest)

ReqResRequestCodec is the prepared avro codec for Request Response Requests

var ReqResResponse string

ReqResResponse is the text file loaded schema for Request Response Resposes

var ReqResResponseCodec = avro.CreateSchema(ReqResResponse)

ReqResResponseCodec is the prepared avro codec for Request Response Resposes

var UnregisterSubRequest string

UnregisterSubRequest is the text file loaded schema for UnregisterSubRequests

var UnregisterSubRequestCodec = avro.CreateSchema(UnregisterSubRequest)

UnregisterSubRequestCodec is the prepared avro codec for UnregisterSubRequests

var UnregisterSubResponse string

UnregisterSubResponse is the text file loaded schema for UnregisterSubResponses

var UnregisterSubResponseCodec = avro.CreateSchema(UnregisterSubResponse)

UnregisterSubResponseCodec is the prepared avro codec for UnregisterSubResponses

Types

type PubRequestType

type PubRequestType struct {
	Topic   string `json:"topic"`
	Payload []byte `json:"payload"`
}

PubRequestType is the struct for an Publish request

type PubResponseType

type PubResponseType struct {
	Error string `json:"error"`
}

PubResponseType is the struct for an Publish response

type RegisterSubRequestType

type RegisterSubRequestType struct {
	Topic string `json:"topic"`
}

RegisterSubRequestType is the struct used for a Register Subscription request

type RegisterSubResponseType

type RegisterSubResponseType struct {
	Subject string `json:"subject"`
	Error   string `json:"error"`
}

RegisterSubResponseType is the struct for a Register Subscription response

type ReqResRequestType

type ReqResRequestType struct {
	Topic   string `json:"topic"`
	Payload []byte `json:"payload"`
	Timeout int32  `json:"timeout"`
}

ReqResRequestType is the struct for an `request respsonse` request

type ReqResResponsetType

type ReqResResponsetType struct {
	Payload []byte `json:"payload"`
	Error   string `json:"error"`
}

ReqResResponsetType is the struct for an `request respsonse` response

type UnregisterSubRequestType

type UnregisterSubRequestType struct {
	Subject string `json:"subject"`
}

UnregisterSubRequestType is the struct for an Unregister Subscription request

type UnregisterSubResponseType

type UnregisterSubResponseType struct {
	Error string `json:"error"`
}

UnregisterSubResponseType is the struct for an Unregister Subscription response