service

Documentation

Index

• type InformersCache
  • func (ic *InformersCache) Run(ctx context.Context, opts ...meta.InformerOption) error
  • func (ic *InformersCache) Subscribe(_ *informer.SubscribeMessage, ...) error

Types

type InformersCache

type InformersCache struct {
	informer.UnimplementedEventStreamServiceServer

	Port int
	// contains filtered or unexported fields
}

InformersCache configures and starts the gRPC service

func (*InformersCache) Run

func (ic *InformersCache) Run(ctx context.Context, opts ...meta.InformerOption) error

func (*InformersCache) Subscribe

func (ic *InformersCache) Subscribe(_ *informer.SubscribeMessage, server informer.EventStreamService_SubscribeServer) error

Subscribe method of the generated protobuf definition