proto

type FunctionClient interface {
	Process(ctx context.Context, in *ProcessRecordRequest, opts ...grpc.CallOption) (*ProcessRecordResponse, error)
}

type FunctionServer interface {
	Process(context.Context, *ProcessRecordRequest) (*ProcessRecordResponse, error)
}

type ProcessRecordRequest struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

type ProcessRecordResponse struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

type Record struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFunctionServer struct {
}