services

Documentation

Index

• func NewComplianceServer() pb.ComplianceServer
• func NewEchoServer() pb.EchoServer
• func NewIAMPolicyServer() iampb.IAMPolicyServer
• func NewIdentityServer() pb.IdentityServer
• func NewLocationsServer() locpb.LocationsServer
• func NewOperationsServer(messagingServer MessagingServer) lropb.OperationsServer
• func NewSequenceServer() pb.SequenceServiceServer
• func NewTestingServer(observerRegistry server.GrpcObserverRegistry) pb.TestingServer
• type Backend
• type BlurbsOutStream
• type MessagingServer
  • func NewMessagingServer(identityServer ReadOnlyIdentityServer) MessagingServer
• type ReadOnlyIdentityServer

Functions

func NewComplianceServer

func NewComplianceServer() pb.ComplianceServer

NewComplianceServer returns a new ComplianceServer for the Showcase API.

func NewEchoServer

func NewEchoServer() pb.EchoServer

NewEchoServer returns a new EchoServer for the Showcase API.

func NewIAMPolicyServer

func NewIAMPolicyServer() iampb.IAMPolicyServer

NewIAMPolicyServer returns a new LocationsServer for the Showcase API.

func NewIdentityServer

func NewIdentityServer() pb.IdentityServer

NewIdentityServer returns a new instance of showcase identity server.

func NewLocationsServer

func NewLocationsServer() locpb.LocationsServer

NewLocationsServer returns a new LocationsServer for the Showcase API.

func NewOperationsServer

func NewOperationsServer(messagingServer MessagingServer) lropb.OperationsServer

NewOperationsServer returns a new OperationsServer for the Showcase API.

func NewSequenceServer

func NewSequenceServer() pb.SequenceServiceServer

NewSequenceServer returns a new SequenceServer for the Showcase API.

func NewTestingServer

func NewTestingServer(observerRegistry server.GrpcObserverRegistry) pb.TestingServer

NewTestingServer returns a new TestingServer for the Showcase API.

Types

type Backend

type Backend struct {
	// Showcase schema
	EchoServer            pb.EchoServer
	IdentityServer        pb.IdentityServer
	MessagingServer       pb.MessagingServer
	SequenceServiceServer pb.SequenceServiceServer
	ComplianceServer      pb.ComplianceServer
	TestingServer         pb.TestingServer

	// Supporting protos
	OperationsServer lropb.OperationsServer
	LocationsServer  locpb.LocationsServer
	IAMPolicyServer  iampb.IAMPolicyServer

	// Other supporting data structures
	StdLog, ErrLog   *log.Logger
	ObserverRegistry server.GrpcObserverRegistry
}

Backend contains the various service backends that will be accessible via one or more transport endpoints.

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.