conn

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(serviceId string, kafkaversion string, kafkahost []string, ...) (kafkaClient *KafkaClient, err error)
  • func (this *KafkaClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) (err error)
  • func (this *KafkaClient) CallNR(callInfo core.CallInfo) (err error)
  • func (this *KafkaClient) Delete(key string) (err error)
  • func (this *KafkaClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error)
  • func (this *KafkaClient) Stop() (err error)
  • func (this *KafkaClient) Unmarshal(data []byte) (*core.RPCInfo, error)
  • func (this *KafkaClient) UnmarshalResult(data []byte) (*core.ResultInfo, error)
• type KafkaService
  • func NewKafkaService(serviceId string, kafkaversion string, kafkahost []string, rpcId string) (kafkaService *KafkaService, err error)
  • func (this *KafkaService) Callback(callinfo core.CallInfo) error
  • func (s *KafkaService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error)
  • func (this *KafkaService) Start(service core.IRpcServer) (err error)
  • func (this *KafkaService) Stop() (err error)
  • func (s *KafkaService) Unmarshal(data []byte) (*core.RPCInfo, error)
• type NatsClient
  • func NewNatsClient(natsaddr string, pushrpcId, receiveId string) (natsClient *NatsClient, err error)
  • func (this *NatsClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) error
  • func (this *NatsClient) CallNR(callInfo core.CallInfo) error
  • func (this *NatsClient) Delete(key string) (err error)
  • func (this *NatsClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error)
  • func (this *NatsClient) Stop() (err error)
  • func (this *NatsClient) Unmarshal(data []byte) (*core.RPCInfo, error)
  • func (this *NatsClient) UnmarshalResult(data []byte) (*core.ResultInfo, error)
• type NatsService
  • func NewNatsService(natsaddr string, rpcId string) (natsService *NatsService, err error)
  • func (this *NatsService) Callback(callinfo core.CallInfo) error
  • func (s *NatsService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error)
  • func (this *NatsService) Start(service core.IRpcServer) (err error)
  • func (this *NatsService) Stop() (err error)
  • func (s *NatsService) Unmarshal(data []byte) (*core.RPCInfo, error)

Types

type KafkaClient

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

func NewKafkaClient

func NewKafkaClient(serviceId string, kafkaversion string, kafkahost []string, pushrpcId, receiveId string) (kafkaClient *KafkaClient, err error)

func (*KafkaClient) Call

func (this *KafkaClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) (err error)

* 消息请求

func (*KafkaClient) CallNR

func (this *KafkaClient) CallNR(callInfo core.CallInfo) (err error)

* 消息请求 不需要回复

func (*KafkaClient) Delete

func (this *KafkaClient) Delete(key string) (err error)

func (*KafkaClient) Marshal

func (this *KafkaClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error)

func (*KafkaClient) Stop

func (this *KafkaClient) Stop() (err error)

func (*KafkaClient) Unmarshal

func (this *KafkaClient) Unmarshal(data []byte) (*core.RPCInfo, error)

func (*KafkaClient) UnmarshalResult

func (this *KafkaClient) UnmarshalResult(data []byte) (*core.ResultInfo, error)

type KafkaService

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

func NewKafkaService

func NewKafkaService(serviceId string, kafkaversion string, kafkahost []string, rpcId string) (kafkaService *KafkaService, err error)

func (*KafkaService) Callback

func (this *KafkaService) Callback(callinfo core.CallInfo) error

func (*KafkaService) MarshalResult

func (s *KafkaService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error)

func (*KafkaService) Start

func (this *KafkaService) Start(service core.IRpcServer) (err error)

func (*KafkaService) Stop

func (this *KafkaService) Stop() (err error)

func (*KafkaService) Unmarshal

func (s *KafkaService) Unmarshal(data []byte) (*core.RPCInfo, error)

type NatsClient

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

func NewNatsClient

func NewNatsClient(natsaddr string, pushrpcId, receiveId string) (natsClient *NatsClient, err error)

func (*NatsClient) Call

func (this *NatsClient) Call(callInfo core.CallInfo, callback chan core.ResultInfo) error

* 消息请求

func (*NatsClient) CallNR

func (this *NatsClient) CallNR(callInfo core.CallInfo) error

* 消息请求 不需要回复

func (*NatsClient) Delete

func (this *NatsClient) Delete(key string) (err error)

func (*NatsClient) Marshal

func (this *NatsClient) Marshal(rpcInfo *core.RPCInfo) ([]byte, error)

func (*NatsClient) Stop

func (this *NatsClient) Stop() (err error)

func (*NatsClient) Unmarshal

func (this *NatsClient) Unmarshal(data []byte) (*core.RPCInfo, error)

func (*NatsClient) UnmarshalResult

func (this *NatsClient) UnmarshalResult(data []byte) (*core.ResultInfo, error)

type NatsService

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

func NewNatsService

func NewNatsService(natsaddr string, rpcId string) (natsService *NatsService, err error)

func (*NatsService) Callback

func (this *NatsService) Callback(callinfo core.CallInfo) error

func (*NatsService) MarshalResult

func (s *NatsService) MarshalResult(resultInfo core.ResultInfo) ([]byte, error)

func (*NatsService) Start

func (this *NatsService) Start(service core.IRpcServer) (err error)

func (*NatsService) Stop

func (this *NatsService) Stop() (err error)

func (*NatsService) Unmarshal

func (s *NatsService) Unmarshal(data []byte) (*core.RPCInfo, error)