server

Documentation

Index

• func Set(ctx context.Context, cfg SetConfig) (*echo.Echo, error)
• func Start(e *echo.Echo) error
• func Stop(e *echo.Echo) error
• type APIRespond
• type Handler
  • func (h Handler) Publish(c echo.Context) error
• type Message
  • func (m Message) MarshalJSON() ([]byte, error)
  • func (m Message) ProducerHook(r *wkafka.Record) *wkafka.Record
• type SetConfig

Functions

func Set

func Set(ctx context.Context, cfg SetConfig) (*echo.Echo, error)

@description github.com/worldline-go/molen @description Authorization as "Bearer TOKEN" or use oauth2 login @BasePath /v1 @securityDefinitions.apikey ApiKeyAuth @in header @name Authorization @securityDefinitions.apikey ApiKeyAuth @in header @name Authorization @securitydefinitions.oauth2.accessCode OAuth2AccessCode @tokenUrl [[ .Custom.tokenUrl ]] @authorizationUrl [[ .Custom.authUrl ]]

func Start

func Start(e *echo.Echo) error

func Stop

func Stop(e *echo.Echo) error

Types

type APIRespond

type APIRespond struct {
	Error   string `json:"error,omitempty"`
	Message string `json:"message,omitempty"`
}

type Handler

type Handler struct {
	Ctx            context.Context //nolint:containedctx // no need
	Client         *wkafka.Client
	ProduceMessage func(ctx context.Context, data ...Message) error
}

func (Handler) Publish

func (h Handler) Publish(c echo.Context) error

@Summary Publish message @Description Publish message(s) to kafka with topic and partition(optional) @Security ApiKeyAuth || OAuth2AccessCode @Router /publish [post] @Param topic query string true "topic name" @Param partition query int32 false "specific partition number" @Param key query string false "key" @Param payload body interface{} false "send key values" SchemaExample() @Param raw query bool false "raw body" @Accept application/json @Success 200 {object} APIRespond{} @failure 400 {object} APIRespond{} @failure 500 {object} APIRespond{}

type Message

type Message struct {
	Data      []byte
	Topic     string
	Partition int32
	Key       []byte
}

func (Message) MarshalJSON

func (m Message) MarshalJSON() ([]byte, error)

func (Message) ProducerHook

func (m Message) ProducerHook(r *wkafka.Record) *wkafka.Record

type SetConfig

type SetConfig struct {
	Client   *wkafka.Client
	Provider auth.InfProviderExtra
}