v1

package
v0.9.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	Map_MapFn_FullMethodName   = "/map.v1.Map/MapFn"
	Map_IsReady_FullMethodName = "/map.v1.Map/IsReady"
)

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: "IsReady",
			Handler:    _Map_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MapFn",
			Handler:       _Map_MapFn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	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 Handshake added in v0.9.0 

type Handshake struct {

	// Required field indicating the start of transmission.
	Sot bool `protobuf:"varint,1,opt,name=sot,proto3" json:"sot,omitempty"`
	// contains filtered or unexported fields
}

Handshake message between client and server to indicate the start of transmission.

func (*Handshake) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Handshake.ProtoReflect.Descriptor instead.

func (*Handshake) GetSot added in v0.9.0 

func (x *Handshake) GetSot() bool

func (*Handshake) ProtoMessage added in v0.9.0 

func (*Handshake) ProtoMessage()

func (*Handshake) ProtoReflect added in v0.9.0 

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

func (*Handshake) Reset added in v0.9.0 

func (x *Handshake) Reset()

func (*Handshake) String added in v0.9.0 

func (x *Handshake) String() string

type MapClient 

type MapClient interface {
	// MapFn applies a function to each map request element.
	MapFn(ctx context.Context, opts ...grpc.CallOption) (Map_MapFnClient, 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 {
	Request *MapRequest_Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// This ID is used to uniquely identify a map request
	Id        string              `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Handshake *Handshake          `protobuf:"bytes,3,opt,name=handshake,proto3,oneof" json:"handshake,omitempty"`
	Status    *TransmissionStatus `protobuf:"bytes,4,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// 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) GetHandshake added in v0.9.0 

func (x *MapRequest) GetHandshake() *Handshake

func (*MapRequest) GetId added in v0.9.0 

func (x *MapRequest) GetId() string

func (*MapRequest) GetRequest added in v0.9.0 

func (x *MapRequest) GetRequest() *MapRequest_Request

func (*MapRequest) GetStatus added in v0.9.0 

func (x *MapRequest) GetStatus() *TransmissionStatus

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 MapRequest_Request added in v0.9.0 

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

func (*MapRequest_Request) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use MapRequest_Request.ProtoReflect.Descriptor instead.

func (*MapRequest_Request) GetEventTime added in v0.9.0 

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

func (*MapRequest_Request) GetHeaders added in v0.9.0 

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

func (*MapRequest_Request) GetKeys added in v0.9.0 

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

func (*MapRequest_Request) GetValue added in v0.9.0 

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

func (*MapRequest_Request) GetWatermark added in v0.9.0 

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

func (*MapRequest_Request) ProtoMessage added in v0.9.0 

func (*MapRequest_Request) ProtoMessage()

func (*MapRequest_Request) ProtoReflect added in v0.9.0 

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

func (*MapRequest_Request) Reset added in v0.9.0 

func (x *MapRequest_Request) Reset()

func (*MapRequest_Request) String added in v0.9.0 

func (x *MapRequest_Request) String() string

type MapResponse 

type MapResponse struct {
	Results []*MapResponse_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// This ID is used to refer the responses to the request it corresponds to.
	Id        string              `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Handshake *Handshake          `protobuf:"bytes,3,opt,name=handshake,proto3,oneof" json:"handshake,omitempty"`
	Status    *TransmissionStatus `protobuf:"bytes,4,opt,name=status,proto3,oneof" json:"status,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) GetHandshake added in v0.9.0 

func (x *MapResponse) GetHandshake() *Handshake

func (*MapResponse) GetId added in v0.9.0 

func (x *MapResponse) GetId() string

func (*MapResponse) GetResults 

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

func (*MapResponse) GetStatus added in v0.9.0 

func (x *MapResponse) GetStatus() *TransmissionStatus

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(Map_MapFnServer) 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 Map_MapFnClient added in v0.9.0 

type Map_MapFnClient interface {
	Send(*MapRequest) error
	Recv() (*MapResponse, error)
	grpc.ClientStream
}

type Map_MapFnServer added in v0.9.0 

type Map_MapFnServer interface {
	Send(*MapResponse) error
	Recv() (*MapRequest, 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 TransmissionStatus added in v0.9.0 

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

Status message to indicate the status of the message.

func (*TransmissionStatus) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TransmissionStatus.ProtoReflect.Descriptor instead.

func (*TransmissionStatus) GetEot added in v0.9.0 

func (x *TransmissionStatus) GetEot() bool

func (*TransmissionStatus) ProtoMessage added in v0.9.0 

func (*TransmissionStatus) ProtoMessage()

func (*TransmissionStatus) ProtoReflect added in v0.9.0 

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

func (*TransmissionStatus) Reset added in v0.9.0 

func (x *TransmissionStatus) Reset()

func (*TransmissionStatus) String added in v0.9.0 

func (x *TransmissionStatus) 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(Map_MapFnServer) 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.