router

Documentation

Index

• Constants
• Variables
• func RouteProduceBodyMapConvert[Req any, Key any, Value any](source stateless.OneToOneFunction[message.Bytes, Req, Key, Value], ...) ...
• func RouteProduceTopicBodyMapConvert[Req any, Key any, Value any](source stateless.OneToOneFunction[message.Bytes, Req, Key, Value], ...) ...
• func WithFlow(input []FlowEntryTopic, output []FlowEntryTopic, stateTable string) runtime.Configuration[*RouteFlow]
• func WithFlowMaterialiseOneToOne[IK any, IV any](input topic.Topic[IK, IV]) runtime.Configuration[*RouteFlow]
• func WithFlowStatefulOneToOne[IK any, IV any, OK any, OV any](input topic.Topic[IK, IV], output topic.Topic[OK, OV], stateTable string) runtime.Configuration[*RouteFlow]
• func WithFlowStatefulOneToTwo[IK any, IV any, OK1 any, OV1 any, OK2 any, OV2 any](input topic.Topic[IK, IV], output1 topic.Topic[OK1, OV1], ...) runtime.Configuration[*RouteFlow]
• func WithFlowStatelessOneToOne[IK any, IV any, OK any, OV any](input topic.Topic[IK, IV], output topic.Topic[OK, OV]) runtime.Configuration[*RouteFlow]
• func WithFlowStatelessOneToTwo[IK any, IV any, OK1 any, OV1 any, OK2 any, OV2 any](input topic.Topic[IK, IV], output1 topic.Topic[OK1, OV1], ...) runtime.Configuration[*RouteFlow]
• func WithRouteBodyMap(...) runtime.Configuration[*RouteProducer]
• func WithRouteProducerRuntime(producer message.Producer) runtime.Configuration[*RouteProducer]
• func WriteError(w http.ResponseWriter, httpStatus int, err error) error
• func WriteJson[R any](w http.ResponseWriter, httpStatus int, r R, f format.Format[R]) error
• type BasicResponse
• type FlowEntries
• type FlowEntry
• type FlowEntryTopic
  • func FlowEntryFromTopic[IK any, IV any](topic topic.Topic[IK, IV]) FlowEntryTopic
• type RouteFlow
  • func NewRouteFlow(configurations ...runtime.Configuration[*RouteFlow]) *RouteFlow
  • func (rp *RouteFlow) Handle(w http.ResponseWriter, req *http.Request)
• type RouteProducer
  • func NewRouteProducer(configurations ...runtime.Configuration[*RouteProducer]) *RouteProducer
  • func (rp *RouteProducer) Handle(w http.ResponseWriter, req *http.Request)
  • func (rp *RouteProducer) Produce(w http.ResponseWriter, req *http.Request) error

Constants

const (
	RouteHeaderPrefix     = "HTTP_HEADER_"
	RouteParamPrefix      = "HTTP_PARAM_"
	RouteRequestKeyHeader = "HTTP_HEADER_X_REQUEST_KEY"
)

Variables

var ErrorRouteGettingRequestBody = errors.New("route getting request body")

var ErrorRouteMappingRequestBody = errors.New("route mapping request body")

var ErrorRouteParsingRequestBody = errors.New("route parsing request body")

var ErrorRouteProducingMessage = errors.New("route producing message")

var ErrorRouteReadingRequestBody = errors.New("route reading request body")

var ErrorWriteJsonFormat = errors.New("write json formatting")

Functions

func RouteProduceBodyMapConvert

func RouteProduceBodyMapConvert[Req any, Key any, Value any](
	source stateless.OneToOneFunction[message.Bytes, Req, Key, Value],
	requestFormat format.Format[Req],
	keyFormat format.Format[Key],
	valueFormat format.Format[Value],
) stateless.OneToOneFunction[message.Bytes, message.Bytes, message.Bytes, message.Bytes]

func RouteProduceTopicBodyMapConvert

func RouteProduceTopicBodyMapConvert[Req any, Key any, Value any](
	source stateless.OneToOneFunction[message.Bytes, Req, Key, Value],
	requestFormat format.Format[Req],
	produceTopic topic.Topic[Key, Value],
) stateless.OneToOneFunction[message.Bytes, message.Bytes, message.Bytes, message.Bytes]

func WithFlow

func WithFlow(input []FlowEntryTopic, output []FlowEntryTopic, stateTable string) runtime.Configuration[*RouteFlow]

configurations

func WithFlowMaterialiseOneToOne

func WithFlowMaterialiseOneToOne[
	IK any,
	IV any,
](
	input topic.Topic[IK, IV],
) runtime.Configuration[*RouteFlow]

func WithFlowStatefulOneToOne

func WithFlowStatefulOneToOne[
	IK any,
	IV any,
	OK any,
	OV any,
](
	input topic.Topic[IK, IV],
	output topic.Topic[OK, OV],
	stateTable string,
) runtime.Configuration[*RouteFlow]

func WithFlowStatefulOneToTwo

func WithFlowStatefulOneToTwo[
	IK any,
	IV any,
	OK1 any,
	OV1 any,
	OK2 any,
	OV2 any,
](
	input topic.Topic[IK, IV],
	output1 topic.Topic[OK1, OV1],
	output2 topic.Topic[OK2, OV2],
	stateTable string,
) runtime.Configuration[*RouteFlow]

func WithFlowStatelessOneToOne

func WithFlowStatelessOneToOne[
	IK any,
	IV any,
	OK any,
	OV any,
](
	input topic.Topic[IK, IV],
	output topic.Topic[OK, OV],
) runtime.Configuration[*RouteFlow]

func WithFlowStatelessOneToTwo

func WithFlowStatelessOneToTwo[
	IK any,
	IV any,
	OK1 any,
	OV1 any,
	OK2 any,
	OV2 any,
](
	input topic.Topic[IK, IV],
	output1 topic.Topic[OK1, OV1],
	output2 topic.Topic[OK2, OV2],
) runtime.Configuration[*RouteFlow]

func WithRouteBodyMap

func WithRouteBodyMap(bodyMap stateless.OneToOneFunction[message.Bytes, message.Bytes, message.Bytes, message.Bytes]) runtime.Configuration[*RouteProducer]

func WithRouteProducerRuntime

func WithRouteProducerRuntime(producer message.Producer) runtime.Configuration[*RouteProducer]

configurations

func WriteError

func WriteError(w http.ResponseWriter, httpStatus int, err error) error

func WriteJson

func WriteJson[R any](w http.ResponseWriter, httpStatus int, r R, f format.Format[R]) error

Types

type BasicResponse

type BasicResponse struct {
	Message string `json:"message"`
}

route

type FlowEntries

type FlowEntries struct {
	Entries []FlowEntry `json:"entries"`
}

type FlowEntry

type FlowEntry struct {
	Input      []FlowEntryTopic `json:"inputs"`
	Output     []FlowEntryTopic `json:"outputs"`
	StateTable string           `json:"state_table"`
}

type FlowEntryTopic

type FlowEntryTopic struct {
	Topic     string `json:"topic"`
	KeyType   string `json:"key_type"`
	ValueType string `json:"value_type"`
}

implementation

func FlowEntryFromTopic

func FlowEntryFromTopic[IK any, IV any](topic topic.Topic[IK, IV]) FlowEntryTopic

type RouteFlow

type RouteFlow struct {
	// contains filtered or unexported fields
}

func NewRouteFlow

func NewRouteFlow(configurations ...runtime.Configuration[*RouteFlow]) *RouteFlow

constructor

func (*RouteFlow) Handle

func (rp *RouteFlow) Handle(w http.ResponseWriter, req *http.Request)

type RouteProducer

type RouteProducer struct {
	// contains filtered or unexported fields
}

implementation

func NewRouteProducer

func NewRouteProducer(configurations ...runtime.Configuration[*RouteProducer]) *RouteProducer

constructor

func (*RouteProducer) Handle

func (rp *RouteProducer) Handle(w http.ResponseWriter, req *http.Request)

func (*RouteProducer) Produce

func (rp *RouteProducer) Produce(w http.ResponseWriter, req *http.Request) error