v1

Documentation

Index

• Variables
• func RegisterMapServer(s grpc.ServiceRegistrar, srv MapServer)
• type MapClient
  • func NewMapClient(cc grpc.ClientConnInterface) MapClient
• type MapRequest
  • func (*MapRequest) Descriptor() ([]byte, []int)
  • func (x *MapRequest) GetEventTime() *timestamppb.Timestamp
  • func (x *MapRequest) GetKeys() []string
  • func (x *MapRequest) GetValue() []byte
  • func (x *MapRequest) GetWatermark() *timestamppb.Timestamp
  • func (*MapRequest) ProtoMessage()
  • func (x *MapRequest) ProtoReflect() protoreflect.Message
  • func (x *MapRequest) Reset()
  • func (x *MapRequest) String() string
• type MapResponse
  • func (*MapResponse) Descriptor() ([]byte, []int)
  • func (x *MapResponse) GetResults() []*MapResponse_Result
  • func (*MapResponse) ProtoMessage()
  • func (x *MapResponse) ProtoReflect() protoreflect.Message
  • func (x *MapResponse) Reset()
  • func (x *MapResponse) String() string
• type MapResponse_Result
  • func (*MapResponse_Result) Descriptor() ([]byte, []int)
  • func (x *MapResponse_Result) GetKeys() []string
  • func (x *MapResponse_Result) GetTags() []string
  • func (x *MapResponse_Result) GetValue() []byte
  • func (*MapResponse_Result) ProtoMessage()
  • func (x *MapResponse_Result) ProtoReflect() protoreflect.Message
  • func (x *MapResponse_Result) Reset()
  • func (x *MapResponse_Result) String() string
• type MapServer
• type ReadyResponse
  • func (*ReadyResponse) Descriptor() ([]byte, []int)
  • func (x *ReadyResponse) GetReady() bool
  • func (*ReadyResponse) ProtoMessage()
  • func (x *ReadyResponse) ProtoReflect() protoreflect.Message
  • func (x *ReadyResponse) Reset()
  • func (x *ReadyResponse) String() string
• type UnimplementedMapServer
  • func (UnimplementedMapServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
  • func (UnimplementedMapServer) MapFn(context.Context, *MapRequest) (*MapResponse, error)
• type UnsafeMapServer

Variables

var File_pkg_apis_proto_map_v1_map_proto protoreflect.FileDescriptor

var Map_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "map.v1.Map",
	HandlerType: (*MapServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MapFn",
			Handler:    _Map_MapFn_Handler,
		},
		{
			MethodName: "IsReady",
			Handler:    _Map_IsReady_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apis/proto/map/v1/map.proto",
}

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

Functions

func RegisterMapServer

func RegisterMapServer(s grpc.ServiceRegistrar, srv MapServer)

Types

type MapClient

type MapClient interface {
	// MapFn applies a function to each map request element.
	MapFn(ctx context.Context, in *MapRequest, opts ...grpc.CallOption) (*MapResponse, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
}

MapClient is the client API for Map 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 NewMapClient

func NewMapClient(cc grpc.ClientConnInterface) MapClient

type MapRequest

type MapRequest struct {
	Keys      []string               `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Value     []byte                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Watermark *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// contains filtered or unexported fields
}

* MapRequest represents a request element.

func (*MapRequest) Descriptor

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

Deprecated: Use MapRequest.ProtoReflect.Descriptor instead.

func (*MapRequest) GetEventTime

func (x *MapRequest) GetEventTime() *timestamppb.Timestamp

func (*MapRequest) GetKeys

func (x *MapRequest) GetKeys() []string

func (*MapRequest) GetValue

func (x *MapRequest) GetValue() []byte

func (*MapRequest) GetWatermark

func (x *MapRequest) GetWatermark() *timestamppb.Timestamp

func (*MapRequest) ProtoMessage

func (*MapRequest) ProtoMessage()

func (*MapRequest) ProtoReflect

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

func (*MapRequest) Reset

func (x *MapRequest) Reset()

func (*MapRequest) String

func (x *MapRequest) String() string

type MapResponse

type MapResponse struct {
	Results []*MapResponse_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

* MapResponse represents a response element.

func (*MapResponse) Descriptor

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

Deprecated: Use MapResponse.ProtoReflect.Descriptor instead.

func (*MapResponse) GetResults

func (x *MapResponse) GetResults() []*MapResponse_Result

func (*MapResponse) ProtoMessage

func (*MapResponse) ProtoMessage()

func (*MapResponse) ProtoReflect

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

func (*MapResponse) Reset

func (x *MapResponse) Reset()

func (*MapResponse) String

func (x *MapResponse) String() string

type MapResponse_Result

type MapResponse_Result struct {
	Keys  []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Value []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Tags  []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*MapResponse_Result) Descriptor

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

Deprecated: Use MapResponse_Result.ProtoReflect.Descriptor instead.

func (*MapResponse_Result) GetKeys

func (x *MapResponse_Result) GetKeys() []string

func (*MapResponse_Result) GetTags

func (x *MapResponse_Result) GetTags() []string

func (*MapResponse_Result) GetValue

func (x *MapResponse_Result) GetValue() []byte

func (*MapResponse_Result) ProtoMessage

func (*MapResponse_Result) ProtoMessage()

func (*MapResponse_Result) ProtoReflect

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

func (*MapResponse_Result) Reset

func (x *MapResponse_Result) Reset()

func (*MapResponse_Result) String

func (x *MapResponse_Result) String() string

type MapServer

type MapServer interface {
	// MapFn applies a function to each map request element.
	MapFn(context.Context, *MapRequest) (*MapResponse, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// contains filtered or unexported methods
}

MapServer is the server API for Map service. All implementations must embed UnimplementedMapServer for forward compatibility

type ReadyResponse

type ReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

* ReadyResponse is the health check result.

func (*ReadyResponse) Descriptor

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

Deprecated: Use ReadyResponse.ProtoReflect.Descriptor instead.

func (*ReadyResponse) GetReady

func (x *ReadyResponse) GetReady() bool

func (*ReadyResponse) ProtoMessage

func (*ReadyResponse) ProtoMessage()

func (*ReadyResponse) ProtoReflect

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

func (*ReadyResponse) Reset

func (x *ReadyResponse) Reset()

func (*ReadyResponse) String

func (x *ReadyResponse) String() string

type UnimplementedMapServer

type UnimplementedMapServer struct {
}

UnimplementedMapServer must be embedded to have forward compatible implementations.

func (UnimplementedMapServer) IsReady

func (UnimplementedMapServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)

func (UnimplementedMapServer) MapFn

func (UnimplementedMapServer) MapFn(context.Context, *MapRequest) (*MapResponse, error)

type UnsafeMapServer

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

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