v1

Documentation

Index

• Variables
• func RegisterReduceServer(s grpc.ServiceRegistrar, srv ReduceServer)
• 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 ReduceClient
  • func NewReduceClient(cc grpc.ClientConnInterface) ReduceClient
• type ReduceRequest
  • func (*ReduceRequest) Descriptor() ([]byte, []int)
  • func (x *ReduceRequest) GetEventTime() *timestamppb.Timestamp
  • func (x *ReduceRequest) GetKeys() []string
  • func (x *ReduceRequest) GetValue() []byte
  • func (x *ReduceRequest) GetWatermark() *timestamppb.Timestamp
  • func (*ReduceRequest) ProtoMessage()
  • func (x *ReduceRequest) ProtoReflect() protoreflect.Message
  • func (x *ReduceRequest) Reset()
  • func (x *ReduceRequest) String() string
• type ReduceResponse
  • func (*ReduceResponse) Descriptor() ([]byte, []int)
  • func (x *ReduceResponse) GetResults() []*ReduceResponse_Result
  • func (*ReduceResponse) ProtoMessage()
  • func (x *ReduceResponse) ProtoReflect() protoreflect.Message
  • func (x *ReduceResponse) Reset()
  • func (x *ReduceResponse) String() string
• type ReduceResponse_Result
  • func (*ReduceResponse_Result) Descriptor() ([]byte, []int)
  • func (x *ReduceResponse_Result) GetKeys() []string
  • func (x *ReduceResponse_Result) GetTags() []string
  • func (x *ReduceResponse_Result) GetValue() []byte
  • func (*ReduceResponse_Result) ProtoMessage()
  • func (x *ReduceResponse_Result) ProtoReflect() protoreflect.Message
  • func (x *ReduceResponse_Result) Reset()
  • func (x *ReduceResponse_Result) String() string
• type ReduceServer
• type Reduce_ReduceFnClient
• type Reduce_ReduceFnServer
• type UnimplementedReduceServer
  • func (UnimplementedReduceServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
  • func (UnimplementedReduceServer) ReduceFn(Reduce_ReduceFnServer) error
• type UnsafeReduceServer

Variables

var File_pkg_apis_proto_reduce_v1_reduce_proto protoreflect.FileDescriptor

var Reduce_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "reduce.v1.Reduce",
	HandlerType: (*ReduceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReady",
			Handler:    _Reduce_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReduceFn",
			Handler:       _Reduce_ReduceFn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/proto/reduce/v1/reduce.proto",
}

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

Functions

func RegisterReduceServer

func RegisterReduceServer(s grpc.ServiceRegistrar, srv ReduceServer)

Types

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 ReduceClient

type ReduceClient interface {
	// ReduceFn applies a reduce function to a request stream.
	ReduceFn(ctx context.Context, opts ...grpc.CallOption) (Reduce_ReduceFnClient, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
}

ReduceClient is the client API for Reduce 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 NewReduceClient

func NewReduceClient(cc grpc.ClientConnInterface) ReduceClient

type ReduceRequest

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

* ReduceRequest represents a request element.

func (*ReduceRequest) Descriptor

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

Deprecated: Use ReduceRequest.ProtoReflect.Descriptor instead.

func (*ReduceRequest) GetEventTime

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

func (*ReduceRequest) GetKeys

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

func (*ReduceRequest) GetValue

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

func (*ReduceRequest) GetWatermark

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

func (*ReduceRequest) ProtoMessage

func (*ReduceRequest) ProtoMessage()

func (*ReduceRequest) ProtoReflect

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

func (*ReduceRequest) Reset

func (x *ReduceRequest) Reset()

func (*ReduceRequest) String

func (x *ReduceRequest) String() string

type ReduceResponse

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

* ReduceResponse represents a response element.

func (*ReduceResponse) Descriptor

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

Deprecated: Use ReduceResponse.ProtoReflect.Descriptor instead.

func (*ReduceResponse) GetResults

func (x *ReduceResponse) GetResults() []*ReduceResponse_Result

func (*ReduceResponse) ProtoMessage

func (*ReduceResponse) ProtoMessage()

func (*ReduceResponse) ProtoReflect

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

func (*ReduceResponse) Reset

func (x *ReduceResponse) Reset()

func (*ReduceResponse) String

func (x *ReduceResponse) String() string

type ReduceResponse_Result

type ReduceResponse_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 (*ReduceResponse_Result) Descriptor

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

Deprecated: Use ReduceResponse_Result.ProtoReflect.Descriptor instead.

func (*ReduceResponse_Result) GetKeys

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

func (*ReduceResponse_Result) GetTags

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

func (*ReduceResponse_Result) GetValue

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

func (*ReduceResponse_Result) ProtoMessage

func (*ReduceResponse_Result) ProtoMessage()

func (*ReduceResponse_Result) ProtoReflect

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

func (*ReduceResponse_Result) Reset

func (x *ReduceResponse_Result) Reset()

func (*ReduceResponse_Result) String

func (x *ReduceResponse_Result) String() string

type ReduceServer

type ReduceServer interface {
	// ReduceFn applies a reduce function to a request stream.
	ReduceFn(Reduce_ReduceFnServer) error
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// contains filtered or unexported methods
}

ReduceServer is the server API for Reduce service. All implementations must embed UnimplementedReduceServer for forward compatibility

type Reduce_ReduceFnClient

type Reduce_ReduceFnClient interface {
	Send(*ReduceRequest) error
	Recv() (*ReduceResponse, error)
	grpc.ClientStream
}

type Reduce_ReduceFnServer

type Reduce_ReduceFnServer interface {
	Send(*ReduceResponse) error
	Recv() (*ReduceRequest, error)
	grpc.ServerStream
}

type UnimplementedReduceServer

type UnimplementedReduceServer struct {
}

UnimplementedReduceServer must be embedded to have forward compatible implementations.

func (UnimplementedReduceServer) IsReady

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

func (UnimplementedReduceServer) ReduceFn

func (UnimplementedReduceServer) ReduceFn(Reduce_ReduceFnServer) error

type UnsafeReduceServer

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

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