rest

Documentation

Index

• func HeartbeatHandler(ctx iris.Context)
• func PartitionHandler(ctx iris.Context)
• func Profiler() iris.Handler
• func TopicHandler(ctx iris.Context)
• func TopicsHandler(ctx iris.Context)
• type PartitionRequestResponse
• type REST
  • func (rest REST) Start() error
• type TopicsRequest

Functions

func HeartbeatHandler

func HeartbeatHandler(ctx iris.Context)

func PartitionHandler

func PartitionHandler(ctx iris.Context)

GET: query entries from a partition PUT: append new entries to a partition. a new partition is created if non-existent. DELETE: delete a partition along with its entries

func Profiler

func Profiler() iris.Handler

func TopicHandler

func TopicHandler(ctx iris.Context)

GET: list all the partition keys under this topic PUT: update the metadata of a topic DELETE: delete a topic

func TopicsHandler

func TopicsHandler(ctx iris.Context)

GET: get list of topics POST: create a new topic DELETE: delete all topics

Types

type PartitionRequestResponse

type PartitionRequestResponse struct {
	Data cache.Entries
}

type REST

type REST struct {
	Port string
}

func (REST) Start

func (rest REST) Start() error

type TopicsRequest

type TopicsRequest struct {
	Topic      string
	Partitions []string
}