Help us shape the future of Go! Take the 2026 Go Developer Survey

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