v1

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_proto_mapstream_v1_mapstream_proto protoreflect.FileDescriptor
View Source 
var MapStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mapstream.v1.MapStream",
	HandlerType: (*MapStreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReady",
			Handler:    _MapStream_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MapStreamFn",
			Handler:       _MapStream_MapStreamFn_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/apis/proto/mapstream/v1/mapstream.proto",
}

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

Functions

func RegisterMapStreamServer 

func RegisterMapStreamServer(s grpc.ServiceRegistrar, srv MapStreamServer)

Types

type MapStreamClient 

type MapStreamClient interface {
	// MapStreamFn applies a function to each request element and returns a stream.
	MapStreamFn(ctx context.Context, in *MapStreamRequest, opts ...grpc.CallOption) (MapStream_MapStreamFnClient, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
}

MapStreamClient is the client API for MapStream 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 NewMapStreamClient 

func NewMapStreamClient(cc grpc.ClientConnInterface) MapStreamClient

type MapStreamRequest 

type MapStreamRequest 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
}

* MapStreamRequest represents a request element.

func (*MapStreamRequest) Descriptor deprecated 

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

Deprecated: Use MapStreamRequest.ProtoReflect.Descriptor instead.

func (*MapStreamRequest) GetEventTime 

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

func (*MapStreamRequest) GetKeys 

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

func (*MapStreamRequest) GetValue 

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

func (*MapStreamRequest) GetWatermark 

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

func (*MapStreamRequest) ProtoMessage 

func (*MapStreamRequest) ProtoMessage()

func (*MapStreamRequest) ProtoReflect 

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

func (*MapStreamRequest) Reset 

func (x *MapStreamRequest) Reset()

func (*MapStreamRequest) String 

func (x *MapStreamRequest) String() string

type MapStreamResponse 

type MapStreamResponse struct {
	Result *MapStreamResponse_Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

* MapStreamResponse represents a response element.

func (*MapStreamResponse) Descriptor deprecated 

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

Deprecated: Use MapStreamResponse.ProtoReflect.Descriptor instead.

func (*MapStreamResponse) GetResult 

func (x *MapStreamResponse) GetResult() *MapStreamResponse_Result

func (*MapStreamResponse) ProtoMessage 

func (*MapStreamResponse) ProtoMessage()

func (*MapStreamResponse) ProtoReflect 

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

func (*MapStreamResponse) Reset 

func (x *MapStreamResponse) Reset()

func (*MapStreamResponse) String 

func (x *MapStreamResponse) String() string

type MapStreamResponse_Result 

type MapStreamResponse_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 (*MapStreamResponse_Result) Descriptor deprecated 

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

Deprecated: Use MapStreamResponse_Result.ProtoReflect.Descriptor instead.

func (*MapStreamResponse_Result) GetKeys 

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

func (*MapStreamResponse_Result) GetTags 

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

func (*MapStreamResponse_Result) GetValue 

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

func (*MapStreamResponse_Result) ProtoMessage 

func (*MapStreamResponse_Result) ProtoMessage()

func (*MapStreamResponse_Result) ProtoReflect 

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

func (*MapStreamResponse_Result) Reset 

func (x *MapStreamResponse_Result) Reset()

func (*MapStreamResponse_Result) String 

func (x *MapStreamResponse_Result) String() string

type MapStreamServer 

type MapStreamServer interface {
	// MapStreamFn applies a function to each request element and returns a stream.
	MapStreamFn(*MapStreamRequest, MapStream_MapStreamFnServer) error
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// contains filtered or unexported methods
}

MapStreamServer is the server API for MapStream service. All implementations must embed UnimplementedMapStreamServer for forward compatibility

type MapStream_MapStreamFnClient 

type MapStream_MapStreamFnClient interface {
	Recv() (*MapStreamResponse, error)
	grpc.ClientStream
}

type MapStream_MapStreamFnServer 

type MapStream_MapStreamFnServer interface {
	Send(*MapStreamResponse) error
	grpc.ServerStream
}

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 UnimplementedMapStreamServer 

type UnimplementedMapStreamServer struct {
}

UnimplementedMapStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedMapStreamServer) IsReady 

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

func (UnimplementedMapStreamServer) MapStreamFn 

func (UnimplementedMapStreamServer) MapStreamFn(*MapStreamRequest, MapStream_MapStreamFnServer) error

type UnsafeMapStreamServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Package mapstreammock is a generated GoMock package.
 Package mapstreammock 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.