server

Documentation

Index

• type GRPCServer
  • func NewGRPCServer() *GRPCServer
  • func (svr *GRPCServer) GetStore() *store.MemoryStore
  • func (svr *GRPCServer) Publish(ctx context.Context, pubReq *pbv1.PublishRequest) (*emptypb.Empty, error)
  • func (svr *GRPCServer) ResourceChan() <-chan *store.Resource
  • func (svr *GRPCServer) Start(addr string, serverOpts []grpc.ServerOption) error
  • func (svr *GRPCServer) Subscribe(subReq *pbv1.SubscriptionRequest, ...) error
  • func (svr *GRPCServer) UpdateResourceStatus(resource *store.Resource) error

Types

type GRPCServer

type GRPCServer struct {
	pbv1.UnimplementedCloudEventServiceServer
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer() *GRPCServer

func NewGRPCServer(eventBroadcaster *store.EventBroadcaster) *GRPCServer {

func (*GRPCServer) GetStore

func (svr *GRPCServer) GetStore() *store.MemoryStore

func (*GRPCServer) Publish

func (svr *GRPCServer) Publish(ctx context.Context, pubReq *pbv1.PublishRequest) (*emptypb.Empty, error)

func (*GRPCServer) ResourceChan

func (svr *GRPCServer) ResourceChan() <-chan *store.Resource

func (*GRPCServer) Start

func (svr *GRPCServer) Start(addr string, serverOpts []grpc.ServerOption) error

func (*GRPCServer) Subscribe

func (svr *GRPCServer) Subscribe(subReq *pbv1.SubscriptionRequest, subServer pbv1.CloudEventService_SubscribeServer) error

func (*GRPCServer) UpdateResourceStatus

func (svr *GRPCServer) UpdateResourceStatus(resource *store.Resource) error