eventing

Documentation

Index

• Constants
• Variables
• type Client
• type Connection
• type Header
• type Message
• type Payload
• type Response
• type Server
  • func (s *Server) Serve()
  • func (s *Server) Setup(workerCount int)
  • func (s *Server) Stop()
• type Worker
  • func (w *Worker) Serve()
  • func (w *Worker) Stop()
• type WorkerID

Constants

const (
	NUM_VBUCKETS int = 1024
)

Variables

var FreeAppWorkerChanMap map[string]chan *Client

var NewAppWorkerChanMap map[string]chan *Worker

Types

type Client

type Client struct {
	Feed *couchbase.DcpFeed
	// contains filtered or unexported fields
}

type Connection

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

type Header

type Header struct {
	Command    string `json:"command"`
	Subcommand string `json:"subcommand"`
	Metadata   string `json:"metadata"`
}

type Message

type Message struct {
	Header  Header
	Payload Payload
	ResChan chan *Response
}

type Payload

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

type Response

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

type Server

type Server struct {
	AppName           string
	ActiveWorkerCount uint32
	RunningWorkers    map[*Client]int
	ConnAcceptQueue   chan Connection

	// Keeps track of different stats of individual client workers
	// i.e. state of each worker("pending", "active"), start vbucket.
	// end vbucket etc
	WorkerStateMap map[int]map[string]interface{}

	WorkerShutdownChanMap map[int]chan bool

	StopAcceptChan chan bool
	StopServerChan chan bool
}

func (*Server) Serve

func (s *Server) Serve()

func (*Server) Setup

func (s *Server) Setup(workerCount int)

Setup initialises some bookeeping needed to track client workers associated with a specific upstream server

func (*Server) Stop

func (s *Server) Stop()

type Worker

type Worker struct {
	AppName string
	ID      WorkerID

	CmdWaitChan chan bool
	StopChan    chan bool
}

func (*Worker) Serve

func (w *Worker) Serve()

func (*Worker) Stop

func (w *Worker) Stop()

type WorkerID

type WorkerID int