v1

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 2024 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"`
	Headers   map[string]string      `` /* 155-byte string literal not displayed */
	// 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) GetHeaders added in v0.7.0

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

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 (*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) MapStreamFn

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.

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