topic

Documentation

Index

• Variables
• func EndpointInstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware
• func EndpointLoggingMiddleware(logger log.Logger) endpoint.Middleware
• func MakeGRPCServer(ctx context.Context, s topic.TopicServer, tracer stdopentracing.Tracer, ...) topic.TopicServer
• func MakeGetTopicEndpoint(s topic.TopicServer, tracer stdopentracing.Tracer, logger log.Logger) endpoint.Endpoint
• func NewTopicService() topic.TopicServer
• type Topic

Variables

var (
	ErrTopicNotFound = errors.New("topic not found")
)

Functions

func EndpointInstrumentingMiddleware

func EndpointInstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware

func EndpointLoggingMiddleware

func EndpointLoggingMiddleware(logger log.Logger) endpoint.Middleware

func MakeGRPCServer

func MakeGRPCServer(ctx context.Context, s topic.TopicServer, tracer stdopentracing.Tracer, logger log.Logger) topic.TopicServer

MakeGRPCServer makes a set of endpoints available as a gRPC AddServer.

func MakeGetTopicEndpoint

func MakeGetTopicEndpoint(s topic.TopicServer, tracer stdopentracing.Tracer, logger log.Logger) endpoint.Endpoint

func NewTopicService

func NewTopicService() topic.TopicServer

NewFeedService returns a naive, stateless implementation of Topic Service.

Types

type Topic

type Topic struct {
	TopicID int64
	Subject string
	Content string
}