Documentation
¶
Index ¶
- func GetClient() topic.TopicClient
- func Init(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger)
- func InitWithSD(sdClient etcd.Client, tracer stdopentracing.Tracer, logger log.Logger)
- func MakeGetTopicEndpoint(f topic.TopicClient) endpoint.Endpoint
- func NewTopicClient(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger) topic.TopicClient
- func NewTopicClientWithSD(sdClient etcd.Client, tracer stdopentracing.Tracer, logger log.Logger) topic.TopicClient
- func TopicFactory(makeEndpoint func(f topic.TopicClient) endpoint.Endpoint, ...) sd.Factory
- type TopicClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetClient ¶
func GetClient() topic.TopicClient
func Init ¶
func Init(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger)
func InitWithSD ¶
func MakeGetTopicEndpoint ¶
func MakeGetTopicEndpoint(f topic.TopicClient) endpoint.Endpoint
func NewTopicClient ¶
func NewTopicClient(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger) topic.TopicClient
func NewTopicClientWithSD ¶
func NewTopicClientWithSD(sdClient etcd.Client, tracer stdopentracing.Tracer, logger log.Logger) topic.TopicClient
func TopicFactory ¶
func TopicFactory(makeEndpoint func(f topic.TopicClient) endpoint.Endpoint, tracer stdopentracing.Tracer, logger log.Logger) sd.Factory
Todo: use connect pool, and reference counting to one connection.
Types ¶
type TopicClient ¶
func (*TopicClient) GetTopic ¶
func (p *TopicClient) GetTopic(ctx context.Context, in *topic.GetTopicRequest, opts ...grpc.CallOption) (*topic.GetTopicResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.