event

Documentation

Index

• Constants
• Variables
• func RegisterCacheServiceServer(s grpc.ServiceRegistrar, srv CacheServiceServer)
• type CacheServiceClient
  • func NewCacheServiceClient(cc grpc.ClientConnInterface) CacheServiceClient
• type CacheServiceServer
• type CacheService_EventsClient
• type CacheService_EventsServer
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (x *Empty) ProtoReflect() protoreflect.Message
  • func (x *Empty) Reset()
  • func (x *Empty) String() string
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetName() string
  • func (x *Event) GetType() Event_EventType
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type Event_EventType
  • func (Event_EventType) Descriptor() protoreflect.EnumDescriptor
  • func (x Event_EventType) Enum() *Event_EventType
  • func (Event_EventType) EnumDescriptor() ([]byte, []int)
  • func (x Event_EventType) Number() protoreflect.EnumNumber
  • func (x Event_EventType) String() string
  • func (Event_EventType) Type() protoreflect.EnumType
• type UnimplementedCacheServiceServer
  • func (UnimplementedCacheServiceServer) Events(*Empty, CacheService_EventsServer) error
• type UnsafeCacheServiceServer

Constants

const (
	CacheService_Events_FullMethodName = "/CacheService/Events"
)

Variables

var (
	Event_EventType_name = map[int32]string{
		0: "Add",
		1: "Update",
		2: "Delete",
		3: "Error",
	}
	Event_EventType_value = map[string]int32{
		"Add":    0,
		"Update": 1,
		"Delete": 2,
		"Error":  3,
	}
)

Enum value maps for Event_EventType.

var CacheService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "CacheService",
	HandlerType: (*CacheServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _CacheService_Events_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "event.proto",
}

CacheService_ServiceDesc is the grpc.ServiceDesc for CacheService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_event_proto protoreflect.FileDescriptor

Functions

func RegisterCacheServiceServer

func RegisterCacheServiceServer(s grpc.ServiceRegistrar, srv CacheServiceServer)

Types

type CacheServiceClient

type CacheServiceClient interface {
	Events(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CacheService_EventsClient, error)
}

CacheServiceClient is the client API for CacheService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCacheServiceClient

func NewCacheServiceClient(cc grpc.ClientConnInterface) CacheServiceClient

type CacheServiceServer

type CacheServiceServer interface {
	Events(*Empty, CacheService_EventsServer) error
	// contains filtered or unexported methods
}

CacheServiceServer is the server API for CacheService service. All implementations must embed UnimplementedCacheServiceServer for forward compatibility

type CacheService_EventsClient

type CacheService_EventsClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type CacheService_EventsServer

type CacheService_EventsServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Empty

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

func (*Empty) Descriptor

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type Event

type Event struct {
	Name string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type Event_EventType `protobuf:"varint,2,opt,name=type,proto3,enum=Event_EventType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetName

func (x *Event) GetName() string

func (*Event) GetType

func (x *Event) GetType() Event_EventType

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Event_EventType

type Event_EventType int32

const (
	Event_Add    Event_EventType = 0
	Event_Update Event_EventType = 1
	Event_Delete Event_EventType = 2
	Event_Error  Event_EventType = 3
)

func (Event_EventType) Descriptor

func (Event_EventType) Descriptor() protoreflect.EnumDescriptor

func (Event_EventType) Enum

func (x Event_EventType) Enum() *Event_EventType

func (Event_EventType) EnumDescriptor

func (Event_EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Event_EventType.Descriptor instead.

func (Event_EventType) Number

func (x Event_EventType) Number() protoreflect.EnumNumber

func (Event_EventType) String

func (x Event_EventType) String() string

func (Event_EventType) Type

func (Event_EventType) Type() protoreflect.EnumType

type UnimplementedCacheServiceServer

type UnimplementedCacheServiceServer struct {
}

UnimplementedCacheServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheServiceServer) Events

func (UnimplementedCacheServiceServer) Events(*Empty, CacheService_EventsServer) error

type UnsafeCacheServiceServer

type UnsafeCacheServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCacheServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServiceServer will result in compilation errors.