Versions in this module Expand all Collapse all v1 v1.0.1 Dec 8, 2016 Changes in this version + 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 struct + GetTopicEndpoint endpoint.Endpoint + func (p *TopicClient) GetTopic(ctx context.Context, in *topic.GetTopicRequest, opts ...grpc.CallOption) (*topic.GetTopicResponse, error)
Go to main page