v1

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_proto_map_v1_map_proto protoreflect.FileDescriptor
View Source 
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"`
	Headers   map[string]string      `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

* MapRequest represents a request element.

func (*MapRequest) Descriptor deprecated 

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

Deprecated: Use MapRequest.ProtoReflect.Descriptor instead.

func (*MapRequest) GetEventTime 

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

func (*MapRequest) GetHeaders added in v0.7.0 

func (x *MapRequest) GetHeaders() map[string]string

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 deprecated 

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 deprecated 

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 deprecated 

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.

Source Files

View all Source files

Directories

Path Synopsis
Package mapmock is a generated GoMock package.
 Package mapmock is a generated GoMock package.

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.