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: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SessionReduceRequest_WindowOperation_Event_name = map[int32]string{
		0: "OPEN",
		1: "CLOSE",
		2: "EXPAND",
		3: "MERGE",
		4: "APPEND",
	}
	SessionReduceRequest_WindowOperation_Event_value = map[string]int32{
		"OPEN":   0,
		"CLOSE":  1,
		"EXPAND": 2,
		"MERGE":  3,
		"APPEND": 4,
	}
)

Enum value maps for SessionReduceRequest_WindowOperation_Event.

View Source 
var File_pkg_apis_proto_sessionreduce_v1_sessionreduce_proto protoreflect.FileDescriptor
View Source 
var SessionReduce_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sessionreduce.v1.SessionReduce",
	HandlerType: (*SessionReduceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReady",
			Handler:    _SessionReduce_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SessionReduceFn",
			Handler:       _SessionReduce_SessionReduceFn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/proto/sessionreduce/v1/sessionreduce.proto",
}

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

Functions

func RegisterSessionReduceServer 

func RegisterSessionReduceServer(s grpc.ServiceRegistrar, srv SessionReduceServer)

Types

type KeyedWindow 

type KeyedWindow struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Slot  string                 `protobuf:"bytes,3,opt,name=slot,proto3" json:"slot,omitempty"`
	Keys  []string               `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

KeyedWindow represents a window with keys. since the client track the keys, we use keyed window.

func (*KeyedWindow) Descriptor deprecated 

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

Deprecated: Use KeyedWindow.ProtoReflect.Descriptor instead.

func (*KeyedWindow) GetEnd 

func (x *KeyedWindow) GetEnd() *timestamppb.Timestamp

func (*KeyedWindow) GetKeys 

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

func (*KeyedWindow) GetSlot 

func (x *KeyedWindow) GetSlot() string

func (*KeyedWindow) GetStart 

func (x *KeyedWindow) GetStart() *timestamppb.Timestamp

func (*KeyedWindow) ProtoMessage 

func (*KeyedWindow) ProtoMessage()

func (*KeyedWindow) ProtoReflect 

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

func (*KeyedWindow) Reset 

func (x *KeyedWindow) Reset()

func (*KeyedWindow) String 

func (x *KeyedWindow) String() string

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 SessionReduceClient 

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

SessionReduceClient is the client API for SessionReduce 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 NewSessionReduceClient 

func NewSessionReduceClient(cc grpc.ClientConnInterface) SessionReduceClient

type SessionReduceRequest 

type SessionReduceRequest struct {
	Payload   *SessionReduceRequest_Payload         `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Operation *SessionReduceRequest_WindowOperation `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

* SessionReduceRequest represents a request element.

func (*SessionReduceRequest) Descriptor deprecated 

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

Deprecated: Use SessionReduceRequest.ProtoReflect.Descriptor instead.

func (*SessionReduceRequest) GetOperation 

func (x *SessionReduceRequest) GetOperation() *SessionReduceRequest_WindowOperation

func (*SessionReduceRequest) GetPayload 

func (x *SessionReduceRequest) GetPayload() *SessionReduceRequest_Payload

func (*SessionReduceRequest) ProtoMessage 

func (*SessionReduceRequest) ProtoMessage()

func (*SessionReduceRequest) ProtoReflect 

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

func (*SessionReduceRequest) Reset 

func (x *SessionReduceRequest) Reset()

func (*SessionReduceRequest) String 

func (x *SessionReduceRequest) String() string

type SessionReduceRequest_Payload 

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

Payload represents a payload element.

func (*SessionReduceRequest_Payload) Descriptor deprecated 

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

Deprecated: Use SessionReduceRequest_Payload.ProtoReflect.Descriptor instead.

func (*SessionReduceRequest_Payload) GetEventTime 

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

func (*SessionReduceRequest_Payload) GetHeaders 

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

func (*SessionReduceRequest_Payload) GetKeys 

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

func (*SessionReduceRequest_Payload) GetValue 

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

func (*SessionReduceRequest_Payload) GetWatermark 

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

func (*SessionReduceRequest_Payload) ProtoMessage 

func (*SessionReduceRequest_Payload) ProtoMessage()

func (*SessionReduceRequest_Payload) ProtoReflect 

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

func (*SessionReduceRequest_Payload) Reset 

func (x *SessionReduceRequest_Payload) Reset()

func (*SessionReduceRequest_Payload) String 

func (x *SessionReduceRequest_Payload) String() string

type SessionReduceRequest_WindowOperation 

type SessionReduceRequest_WindowOperation struct {
	Event        SessionReduceRequest_WindowOperation_Event `` /* 129-byte string literal not displayed */
	KeyedWindows []*KeyedWindow                             `protobuf:"bytes,2,rep,name=keyedWindows,proto3" json:"keyedWindows,omitempty"`
	// contains filtered or unexported fields
}

WindowOperation represents a window operation. For Aligned window values can be one of OPEN, CLOSE, EXPAND, MERGE and APPEND.

func (*SessionReduceRequest_WindowOperation) Descriptor deprecated 

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

Deprecated: Use SessionReduceRequest_WindowOperation.ProtoReflect.Descriptor instead.

func (*SessionReduceRequest_WindowOperation) GetEvent 

func (x *SessionReduceRequest_WindowOperation) GetEvent() SessionReduceRequest_WindowOperation_Event

func (*SessionReduceRequest_WindowOperation) GetKeyedWindows 

func (x *SessionReduceRequest_WindowOperation) GetKeyedWindows() []*KeyedWindow

func (*SessionReduceRequest_WindowOperation) ProtoMessage 

func (*SessionReduceRequest_WindowOperation) ProtoMessage()

func (*SessionReduceRequest_WindowOperation) ProtoReflect 

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

func (*SessionReduceRequest_WindowOperation) Reset 

func (x *SessionReduceRequest_WindowOperation) Reset()

func (*SessionReduceRequest_WindowOperation) String 

func (x *SessionReduceRequest_WindowOperation) String() string

type SessionReduceRequest_WindowOperation_Event 

type SessionReduceRequest_WindowOperation_Event int32
const (
	SessionReduceRequest_WindowOperation_OPEN   SessionReduceRequest_WindowOperation_Event = 0
	SessionReduceRequest_WindowOperation_CLOSE  SessionReduceRequest_WindowOperation_Event = 1
	SessionReduceRequest_WindowOperation_EXPAND SessionReduceRequest_WindowOperation_Event = 2
	SessionReduceRequest_WindowOperation_MERGE  SessionReduceRequest_WindowOperation_Event = 3
	SessionReduceRequest_WindowOperation_APPEND SessionReduceRequest_WindowOperation_Event = 4
)

func (SessionReduceRequest_WindowOperation_Event) Descriptor 

func (SessionReduceRequest_WindowOperation_Event) Descriptor() protoreflect.EnumDescriptor

func (SessionReduceRequest_WindowOperation_Event) Enum 

func (x SessionReduceRequest_WindowOperation_Event) Enum() *SessionReduceRequest_WindowOperation_Event

func (SessionReduceRequest_WindowOperation_Event) EnumDescriptor deprecated 

func (SessionReduceRequest_WindowOperation_Event) EnumDescriptor() ([]byte, []int)

Deprecated: Use SessionReduceRequest_WindowOperation_Event.Descriptor instead.

func (SessionReduceRequest_WindowOperation_Event) Number 

func (x SessionReduceRequest_WindowOperation_Event) Number() protoreflect.EnumNumber

func (SessionReduceRequest_WindowOperation_Event) String 

func (x SessionReduceRequest_WindowOperation_Event) String() string

func (SessionReduceRequest_WindowOperation_Event) Type 

func (SessionReduceRequest_WindowOperation_Event) Type() protoreflect.EnumType

type SessionReduceResponse 

type SessionReduceResponse struct {
	Result *SessionReduceResponse_Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// keyedWindow represents a window to which the result belongs.
	KeyedWindow *KeyedWindow `protobuf:"bytes,2,opt,name=keyedWindow,proto3" json:"keyedWindow,omitempty"`
	// EOF represents the end of the response for a window.
	EOF bool `protobuf:"varint,3,opt,name=EOF,proto3" json:"EOF,omitempty"`
	// contains filtered or unexported fields
}

* SessionReduceResponse represents a response element.

func (*SessionReduceResponse) Descriptor deprecated 

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

Deprecated: Use SessionReduceResponse.ProtoReflect.Descriptor instead.

func (*SessionReduceResponse) GetEOF 

func (x *SessionReduceResponse) GetEOF() bool

func (*SessionReduceResponse) GetKeyedWindow 

func (x *SessionReduceResponse) GetKeyedWindow() *KeyedWindow

func (*SessionReduceResponse) GetResult 

func (x *SessionReduceResponse) GetResult() *SessionReduceResponse_Result

func (*SessionReduceResponse) ProtoMessage 

func (*SessionReduceResponse) ProtoMessage()

func (*SessionReduceResponse) ProtoReflect 

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

func (*SessionReduceResponse) Reset 

func (x *SessionReduceResponse) Reset()

func (*SessionReduceResponse) String 

func (x *SessionReduceResponse) String() string

type SessionReduceResponse_Result 

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

Result represents a result element. It contains the result of the reduce function.

func (*SessionReduceResponse_Result) Descriptor deprecated 

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

Deprecated: Use SessionReduceResponse_Result.ProtoReflect.Descriptor instead.

func (*SessionReduceResponse_Result) GetKeys 

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

func (*SessionReduceResponse_Result) GetTags 

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

func (*SessionReduceResponse_Result) GetValue 

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

func (*SessionReduceResponse_Result) ProtoMessage 

func (*SessionReduceResponse_Result) ProtoMessage()

func (*SessionReduceResponse_Result) ProtoReflect 

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

func (*SessionReduceResponse_Result) Reset 

func (x *SessionReduceResponse_Result) Reset()

func (*SessionReduceResponse_Result) String 

func (x *SessionReduceResponse_Result) String() string

type SessionReduceServer 

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

SessionReduceServer is the server API for SessionReduce service. All implementations must embed UnimplementedSessionReduceServer for forward compatibility

type SessionReduce_SessionReduceFnClient 

type SessionReduce_SessionReduceFnClient interface {
	Send(*SessionReduceRequest) error
	Recv() (*SessionReduceResponse, error)
	grpc.ClientStream
}

type SessionReduce_SessionReduceFnServer 

type SessionReduce_SessionReduceFnServer interface {
	Send(*SessionReduceResponse) error
	Recv() (*SessionReduceRequest, error)
	grpc.ServerStream
}

type UnimplementedSessionReduceServer 

type UnimplementedSessionReduceServer struct {
}

UnimplementedSessionReduceServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionReduceServer) IsReady 

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

func (UnimplementedSessionReduceServer) SessionReduceFn 

func (UnimplementedSessionReduceServer) SessionReduceFn(SessionReduce_SessionReduceFnServer) error

type UnsafeSessionReduceServer 

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

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

Source Files

View all Source files

Directories

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