srv

Documentation

Index

• Constants
• Variables
• func NewTags(opts *Options) []string
• type Option
  • func AfterStart(fn func()) Option
  • func AfterStop(fn func()) Option
  • func BeforeStart(fn func()) Option
  • func BeforeStop(fn func()) Option
  • func SetHost(host string) Option
  • func SetName(n string) Option
  • func SetPort(port string) Option
  • func SetRegistry(r *api.Client) Option
  • func SetRegistryTTL(t time.Duration) Option
  • func SetServer(s http.Handler) Option
  • func SetVersion(v string) Option
• type Options
• type Resolver
  • func NewResolver(client *api.Client, service, tag string) (*Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) Next() ([]*naming.Update, error)
  • func (r *Resolver) Resolve(target string) (naming.Watcher, error)
• type Service
  • func NewService(opts ...Option) Service

Constants

const (
	GRPC = iota
	GIN
)

server type list

Variables

var (
	// DefaultRegistry -
	DefaultRegistry = newRegistry()
	// DefaultRegistryTTL - default
	DefaultRegistryTTL = 30 * time.Second
)

var (
	// DefaultServer -
	DefaultServer = newRPCServer()
	// DefaultHost -
	DefaultHost = newHost()
	// DefaultPort -
	DefaultPort = "0"
	// DefaultHook -
	DefaultHook = func() {}
)

var ServerType int

ServerType -

Functions

func NewTags

func NewTags(opts *Options) []string

NewTags -

Types

type Option

type Option func(*Options)

Option -

func AfterStart

func AfterStart(fn func()) Option

AfterStart -

func AfterStop

func AfterStop(fn func()) Option

AfterStop -

func BeforeStart

func BeforeStart(fn func()) Option

BeforeStart -

func BeforeStop

func BeforeStop(fn func()) Option

BeforeStop -

func SetHost

func SetHost(host string) Option

SetHost -

func SetName

func SetName(n string) Option

SetName of the service

func SetPort

func SetPort(port string) Option

SetPort -

func SetRegistry

func SetRegistry(r *api.Client) Option

SetRegistry -

func SetRegistryTTL

func SetRegistryTTL(t time.Duration) Option

SetRegistryTTL -

func SetServer

func SetServer(s http.Handler) Option

SetServer -

func SetVersion

func SetVersion(v string) Option

SetVersion of the service

type Options

type Options struct {
	Server   http.Handler
	Host     string
	Port     string
	Listener net.Listener
	// Registry Client
	Registry *api.Client
	// Registry TTL
	RegistryTTL time.Duration

	// Before and After funcs
	BeforeStart func()
	BeforeStop  func()
	AfterStart  func()
	AfterStop   func()
	// contains filtered or unexported fields
}

Options -

type Resolver

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

Resolver implements the gRPC Resolver interface using a Consul backend.

func NewResolver

func NewResolver(client *api.Client, service, tag string) (*Resolver, error)

NewResolver initializes and returns a new Resolver.

func (*Resolver) Close

func (r *Resolver) Close()

Close closes the watcher.

func (*Resolver) Next

func (r *Resolver) Next() ([]*naming.Update, error)

Next -

func (*Resolver) Resolve

func (r *Resolver) Resolve(target string) (naming.Watcher, error)

by Resolver as well, see Next and Close.

type Service

type Service interface {
	// The service id
	ID() string
	// The service name
	Name() string
	// Initialize
	Init(...Option)
	// Version
	Version() string
	// Run the service
	Run() error
	// Options returns the current options
	Options() Options
	// The server
	Server() http.Handler
	// The server type
	ServerType() string
}

Service -

func NewService

func NewService(opts ...Option) Service

NewService - creates and returns a new Service