serialization

Documentation

Index

• func ReadErrorResponse(resp *http.Response) error
• func ReadOkResponse(resp *http.Response) ([]TopicRecords, error)
• type RegisterConsumerInfo

Functions

func ReadErrorResponse

func ReadErrorResponse(resp *http.Response) error

func ReadOkResponse

func ReadOkResponse(resp *http.Response) ([]TopicRecords, error)

Types

type RegisterConsumerInfo

type RegisterConsumerInfo struct {
	Id     string   `json:"id"`
	Group  string   `json:"group"`
	Topics []string `json:"topics"`
}

Message for registering a consumer