micro

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 19, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultMetaKey = "getty-micro-meta-key"
)
View Source
const (
	ErrIllegalConf = "illegal conf "
)

Variables

This section is empty.

Functions

func GetServiceNodeMetadata added in v1.0.3

func GetServiceNodeMetadata(service *gxregistry.Service) string

Types

type Client

type Client struct {
	ClientOptions
	*rpc.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(conf *rpc.ClientConfig, regConf *ConsumerRegistryConfig, opts ...ClientOption) (*Client, error)

NewServer initialize a micro service consumer

func (*Client) AsyncCall added in v1.0.3

func (c *Client) AsyncCall(ctx context.Context, typ rpc.CodecType, service, version, method string,
	args interface{}, callback rpc.AsyncCallback, reply interface{}, opts ...rpc.CallOption) error

func (*Client) Call

func (c *Client) Call(ctx context.Context, typ rpc.CodecType, service, version, method string,
	args interface{}, reply interface{}, opts ...rpc.CallOption) error

func (*Client) CallOneway added in v1.0.3

func (c *Client) CallOneway(ctx context.Context, typ rpc.CodecType, service, version, method string,
	args interface{}, opts ...rpc.CallOption) error

func (*Client) Close

func (c *Client) Close()

type ClientOption

type ClientOption func(*ClientOptions)

func WithServiceHash

func WithServiceHash(hash gxfilter.ServiceHash) ClientOption

type ClientOptions

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

type ConsumerRegistryConfig

type ConsumerRegistryConfig struct {
	RegistryConfig `yaml:"basic" json:"basic,omitempty"`
	Group          string `default:"idc-bj" yaml:"group" json:"group,omitempty"`
}

ConsumerRegistryConfig provides consumer configuration for registry

func (*ConsumerRegistryConfig) CheckValidity

func (c *ConsumerRegistryConfig) CheckValidity() error

CheckValidity check parameter validity

type ProviderRegistryConfig

type ProviderRegistryConfig struct {
	RegistryConfig `yaml:"basic" json:"basic,omitempty"`
	ServiceArray   []ServiceConfig `default:"" yaml:"service_array" json:"service_array,omitempty"`
}

ProviderRegistryConfig provides provider configuration for registry

func (*ProviderRegistryConfig) CheckValidity

func (c *ProviderRegistryConfig) CheckValidity() error

CheckValidity check parameter validity

type RegistryConfig

type RegistryConfig struct {
	Type             string `default:"etcd" yaml:"type" json:"type,omitempty"`
	RegAddr          string `default:"127.0.0.1:2181" yaml:"reg_addr" json:"reg_addr,omitempty"`
	KeepaliveTimeout int    `default:"5" yaml:"keepalive_timeout" json:"keepalive_timeout,omitempty"`
	Root             string `default:"/getty" yaml:"root" json:"root,omitempty"`
}

RegistryConfig provides configuration for registry

func (*RegistryConfig) CheckValidity

func (c *RegistryConfig) CheckValidity() error

CheckValidity check parameter validity

type Server

type Server struct {
	*rpc.Server
	// contains filtered or unexported fields
}

Server micro service provider

func NewServer

func NewServer(conf *rpc.ServerConfig, regConf *ProviderRegistryConfig) (*Server, error)

NewServer initialize a micro service provider

func (*Server) Register

func (s *Server) Register(rcvr rpc.GettyRPCService) error

Register the @rcvr

type ServiceConfig

type ServiceConfig struct {
	LocalHost string `default:"127.0.0.1" yaml:"local_host" json:"local_host, omitempty"`
	LocalPort int    `default:"10001" yaml:"local_port" json:"local_port, omitempty"`
	Group     string `default:"idc-bj" yaml:"group" json:"group,omitempty"`
	NodeID    string `default:"node0" yaml:"node_id" json:"node_id,omitempty"`
	Protocol  string `default:"json" yaml:"protocol" json:"protocol,omitempty"`
	Service   string `default:"test" yaml:"service" json:"service,omitempty"`
	Version   string `default:"v1" yaml:"version" json:"version,omitempty"`
	Meta      string `default:"default-meta" yaml:"meta" json:"meta,omitempty"`
}

func (*ServiceConfig) CheckValidity

func (c *ServiceConfig) CheckValidity() error

CheckValidity check parameter validity

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL