services

Documentation

Index

• func StartNode()
• type Config
  • func ReadYaml() *Config
• type Count
• type Health
  • func NewHealth(config *Config) *Health
• type Node
• type NodeHealth
• type QNode
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Dequeue() (bool, []byte)
  • func (q *Queue) DequeueMany(count int) (bool, *[][]byte)
  • func (q *Queue) Enqueue(value []byte)

Functions

func StartNode

func StartNode()

Types

type Config

type Config struct {
	Server struct {
		Host string `yaml:"host"`
		Port string `yaml:"port"`
	} `yaml:"server"`
	Node     []Node `yaml:"node"`
	Internal struct {
		Target string `yaml:"target"`
		Scheme string `yaml:"scheme"`
	} `yaml:"internal"`
}

func ReadYaml

func ReadYaml() *Config

type Count

type Count struct {
	Count  int
	Index  int
	Length int
}

type Health

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

func NewHealth

func NewHealth(config *Config) *Health

type Node

type Node struct {
	Name string `yaml:"-"`
	// Host   string `yaml:"host"`
	// Port   string `yaml:"port"`
	Target []string `yaml:"target"`
	Path   string   `yaml:"path"`
	Scheme string   `yaml:"scheme"`
	Config *Count
	Health string `yaml:"health"`
}

type NodeHealth

type NodeHealth struct {
	Name    string
	Success int
	Error   int
	// contains filtered or unexported fields
}

type QNode

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

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) Dequeue

func (q *Queue) Dequeue() (bool, []byte)

func (*Queue) DequeueMany

func (q *Queue) DequeueMany(count int) (bool, *[][]byte)

func (*Queue) Enqueue

func (q *Queue) Enqueue(value []byte)