grpc

package
v0.0.0-...-4fdd5d5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 14, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitFlags 

func InitFlags()

func RegisterSubscriberFactory 

func RegisterSubscriberFactory(factory SubscriberFactory)

func StartGrpc 

func StartGrpc(ctx context.Context) error

Types

type EventService 

type EventService struct {
	// contains filtered or unexported fields
}

func (*EventService) Get 

func (s *EventService) Get(ctx context.Context, get *v1.EventGetRequest) (*v1.CloudEventResponse, error)

func (*EventService) ReStore 

func (s *EventService) ReStore(ctx context.Context, request *v1.CloudEventStoreRequest) (*v1.CloudEventStoreResult, error)

func (*EventService) Store 

func (s *EventService) Store(ctx context.Context, request *v1.CloudEventStoreRequest) (*v1.CloudEventStoreResult, error)

func (*EventService) Subscribe 

func (s *EventService) Subscribe(request *v1.SubscribeRequest, server v1.PublicEventService_SubscribeServer) error

func (*EventService) SubscribeWithHandler 

func (s *EventService) SubscribeWithHandler(handler subscribeHandler, custom func(options badger.IteratorOptions) badger.IteratorOptions, filter *regexp.Regexp) error

type KeyValueService 

type KeyValueService struct {
}

func (*KeyValueService) Get 

func (k *KeyValueService) Get(ctx context.Context, request *v1.GetRequest) (*v1.GetResponse, error)

func (*KeyValueService) Put 

func (k *KeyValueService) Put(ctx context.Context, request *v1.PutRequest) (*v1.PutResponse, error)

type Subscriber 

type Subscriber interface {
	Start(ctx context.Context) error
	// contains filtered or unexported methods
}

type SubscriberFactory 

type SubscriberFactory func(kvsvc *KeyValueService, evsvc *EventService) Subscriber

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.