services

Documentation

Index

• func NewEchoServer() pb.EchoServer
• func NewIdentityServer() pb.IdentityServer
• func NewOperationsServer(messagingServer MessagingServer) lropb.OperationsServer
• func NewTestingServer(observerRegistry server.GrpcObserverRegistry) pb.TestingServer
• type BlurbsOutStream
• type MessagingServer
  • func NewMessagingServer(identityServer ReadOnlyIdentityServer) MessagingServer
• type ReadOnlyIdentityServer

Functions

func NewEchoServer

func NewEchoServer() pb.EchoServer

NewEchoServer returns a new EchoServer for the Showcase API.

func NewIdentityServer

func NewIdentityServer() pb.IdentityServer

NewIdentityServer returns a new instance of showcase identity server.

func NewOperationsServer

func NewOperationsServer(messagingServer MessagingServer) lropb.OperationsServer

NewOperationsServer returns a new OperationsServer for the Showcase API.

func NewTestingServer

func NewTestingServer(observerRegistry server.GrpcObserverRegistry) pb.TestingServer

NewTestingServer returns a new TestingServer for the Showcase API.

Types

type BlurbsOutStream

type BlurbsOutStream interface {
	Send(*pb.StreamBlurbsResponse) error
}

BlurbsOutStream is the common interface of the connect and streamblurbs streams. This interface allows the observer to handle both streams.

type MessagingServer

type MessagingServer interface {
	FilteredListBlurbs(context.Context, *pb.ListBlurbsRequest, func(*pb.Blurb) bool) (*pb.ListBlurbsResponse, error)

	pb.MessagingServer
}

MessagingServer provides an interface which is the implementation of the MessagingServer proto and as well as a method for filtering the blurbs.

func NewMessagingServer

func NewMessagingServer(identityServer ReadOnlyIdentityServer) MessagingServer

NewMessagingServer returns an instance of a messaging server.

type ReadOnlyIdentityServer

type ReadOnlyIdentityServer interface {
	GetUser(context.Context, *pb.GetUserRequest) (*pb.User, error)
	ListUsers(context.Context, *pb.ListUsersRequest) (*pb.ListUsersResponse, error)
}

ReadOnlyIdentityServer provides a read-only interface of an identity server.