transport

Documentation

Index

• func WriteResponse[T fmt.Stringer](w http.ResponseWriter, statusCode int, responseBody *T)
• type ErrorResponse
  • func NewErrorResponse(message string) *ErrorResponse
  • func (er ErrorResponse) String() string
• type Message
  • func (m Message) String() string
• type PublishedResponse
  • func NewPublishedResponse(message string, offset int) *PublishedResponse
  • func (pr PublishedResponse) String() string

Functions

func WriteResponse

func WriteResponse[T fmt.Stringer](w http.ResponseWriter, statusCode int, responseBody *T)

Types

type ErrorResponse

type ErrorResponse struct {
	Message string
}

func NewErrorResponse

func NewErrorResponse(message string) *ErrorResponse

func (ErrorResponse) String

func (er ErrorResponse) String() string

type Message

type Message struct {
	Topic string
	Data  []byte
}

func (Message) String

func (m Message) String() string

type PublishedResponse

type PublishedResponse struct {
	Message string
	Offset  int
}

func NewPublishedResponse

func NewPublishedResponse(message string, offset int) *PublishedResponse

func (PublishedResponse) String

func (pr PublishedResponse) String() string