service

Documentation

Index

• type Peer
• type PeerClient
• type ServiceHandler
  • func (s *ServiceHandler) Add(ld *loader.Partition)
  • func (s *ServiceHandler) AddOrUpdatePeer(peer *Peer)
  • func (s *ServiceHandler) Handle(ctx *fasthttp.RequestCtx)
  • func (s *ServiceHandler) Init()

Types

type Peer

type Peer struct {
	Name       string
	Client     PeerClient
	Partitions []string
}

type PeerClient

type PeerClient interface {
	DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error
}

type ServiceHandler

type ServiceHandler struct {
	Partitions map[string]loader.Partition
	// contains filtered or unexported fields
}

func (*ServiceHandler) Add

func (s *ServiceHandler) Add(ld *loader.Partition)

func (*ServiceHandler) AddOrUpdatePeer

func (s *ServiceHandler) AddOrUpdatePeer(peer *Peer)

func (*ServiceHandler) Handle

func (s *ServiceHandler) Handle(ctx *fasthttp.RequestCtx)

func (*ServiceHandler) Init

func (s *ServiceHandler) Init()