micro

Documentation

Index

• Constants
• func GetServiceNodeMetadata(service *gxregistry.Service) string
• type Client
  • func NewClient(conf *rpc.ClientConfig, regConf *ConsumerRegistryConfig, opts ...ClientOption) (*Client, error)
  • func (c *Client) AsyncCall(ctx context.Context, typ rpc.CodecType, service, version, method string, ...) error
  • func (c *Client) Call(ctx context.Context, typ rpc.CodecType, service, version, method string, ...) error
  • func (c *Client) CallOneway(ctx context.Context, typ rpc.CodecType, service, version, method string, ...) error
  • func (c *Client) Close()
• type ClientOption
  • func WithServiceHash(hash gxfilter.ServiceHash) ClientOption
• type ClientOptions
• type ConsumerRegistryConfig
  • func (c *ConsumerRegistryConfig) CheckValidity() error
• type ProviderRegistryConfig
  • func (c *ProviderRegistryConfig) CheckValidity() error
• type RegistryConfig
  • func (c *RegistryConfig) CheckValidity() error
• type Server
  • func NewServer(conf *rpc.ServerConfig, regConf *ProviderRegistryConfig) (*Server, error)
  • func (s *Server) Register(rcvr rpc.GettyRPCService) error
• type ServiceConfig
  • func (c *ServiceConfig) CheckValidity() error

Constants

const (
	DefaultMetaKey = "getty-micro-meta-key"
)

const (
	ErrIllegalConf = "illegal conf "
)

Functions

func GetServiceNodeMetadata

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

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

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