topic

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
  • func (p *TopicClient) GetTopic(ctx context.Context, in *topic.GetTopicRequest, opts ...grpc.CallOption) (*topic.GetTopicResponse, error)

Functions

func GetClient

func GetClient() topic.TopicClient

func Init

func Init(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger)

func InitWithSD

func InitWithSD(sdClient etcd.Client, tracer stdopentracing.Tracer, logger log.Logger)

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

type TopicClient struct {
	GetTopicEndpoint endpoint.Endpoint
}

func (*TopicClient) GetTopic

func (p *TopicClient) GetTopic(ctx context.Context, in *topic.GetTopicRequest, opts ...grpc.CallOption) (*topic.GetTopicResponse, error)