grpc

Documentation

Index

• func InitFlags()
• func RegisterSubscriberFactory(factory SubscriberFactory)
• func StartGrpc(ctx context.Context) error
• type EventService
  • func (s *EventService) Get(ctx context.Context, get *v1.EventGetRequest) (*v1.CloudEventResponse, error)
  • func (s *EventService) ReStore(ctx context.Context, request *v1.CloudEventStoreRequest) (*v1.CloudEventStoreResult, error)
  • func (s *EventService) Store(ctx context.Context, request *v1.CloudEventStoreRequest) (*v1.CloudEventStoreResult, error)
  • func (s *EventService) Subscribe(request *v1.SubscribeRequest, server v1.PublicEventService_SubscribeServer) error
  • func (s *EventService) SubscribeWithHandler(handler subscribeHandler, ...) error
• type KeyValueService
  • func (k *KeyValueService) Get(ctx context.Context, request *v1.GetRequest) (*v1.GetResponse, error)
  • func (k *KeyValueService) Put(ctx context.Context, request *v1.PutRequest) (*v1.PutResponse, error)
• type Subscriber
• type SubscriberFactory

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